VladaZakharova commented on code in PR #39716:
URL: https://github.com/apache/airflow/pull/39716#discussion_r1626164840
##########
airflow/providers/google/cloud/operators/dataflow.py:
##########
@@ -1358,3 +1359,236 @@ def execute(self, context: Context) -> None:
self.log.info("No jobs to stop")
return None
+
+
+class DataflowCreatePipelineOperator(GoogleCloudBaseOperator):
Review Comment:
Thank you for checking my changes :)
Current PR was created to get rid of exactly this DataPipeline as a separate
service inside Google since this is a part of Dataflow itself. Right now in all
the operators we have both in Dataflow and Apache Beam the Pipeline object
refers to exactly the Pipeline. Currently all the operators skip this step with
creating separate Pipeline object but take its configuration and run it to
create a Job.
In my understanding changing this name here in this PR will lead to
countless changes in other operators 🥲
--
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]
