ashokballolli commented on code in PR #77069:
URL: https://github.com/apache/airflow/pull/77069#discussion_r4569441125
##########
providers/google/docs/operators/cloud/dataflow.rst:
##########
@@ -410,6 +410,12 @@ This operator can be run in deferrable mode by passing
``deferrable=True`` as a
:start-after: [START howto_sensor_wait_for_job_status_deferrable]
:end-before: [END howto_sensor_wait_for_job_status_deferrable]
+If the job is started outside Airflow and its ID is not known, you can pass
``job_name`` instead of
+``job_id``. Job names are not unique in Dataflow, so the sensor checks the
latest created job with that
+name. If no job with that name exists yet, the sensor keeps waiting. If the
same job name is used for every
+run, add something unique like the date to the name, for example ``my-job-{{
ds_nodash }}``. Otherwise the
+sensor can pick up the previous run before the new run starts.
Review Comment:
Updated with this text, thanks
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
