@@ -499,6 +499,7 @@ class DataflowTemplatedJobStartOperator(BaseOperator):
499
499
<https://cloud.google.com/dataflow/docs/reference/rest/v1b3/RuntimeEnvironment>`__
500
500
:param cancel_timeout: How long (in seconds) operator should wait for the pipeline to be
501
501
successfully cancelled when task is being killed.
502
+ :param append_job_name: True if unique suffix has to be appended to job name.
502
503
:param wait_until_finished: (Optional)
503
504
If True, wait for the end of pipeline execution before exiting.
504
505
If False, only submits job.
@@ -612,6 +613,7 @@ def __init__(
612
613
environment : Optional [Dict ] = None ,
613
614
cancel_timeout : Optional [int ] = 10 * 60 ,
614
615
wait_until_finished : Optional [bool ] = None ,
616
+ append_job_name : bool = True ,
615
617
** kwargs ,
616
618
) -> None :
617
619
super ().__init__ (** kwargs )
@@ -631,6 +633,7 @@ def __init__(
631
633
self .environment = environment
632
634
self .cancel_timeout = cancel_timeout
633
635
self .wait_until_finished = wait_until_finished
636
+ self .append_job_name = append_job_name
634
637
635
638
def execute (self , context : 'Context' ) -> dict :
636
639
self .hook = DataflowHook (
@@ -657,6 +660,7 @@ def set_current_job(current_job):
657
660
project_id = self .project_id ,
658
661
location = self .location ,
659
662
environment = self .environment ,
663
+ append_job_name = self .append_job_name ,
660
664
)
661
665
662
666
return job
0 commit comments