[PR] Add ability to run streaming Job for BeamRunPythonPipelineOperator in non deferrable mode [airflow]

MaksYermak opened a new pull request, #36108: URL: https://github.com/apache/airflow/pull/36108 In this PR I have fixed the problem when a Streaming Job, which is run by `BeamRunPythonPipelineOperator`, blocks the starting of the next task in the DAG. Expected behavior for t

Re: [PR] Add ability to run streaming Job for BeamRunPythonPipelineOperator in non deferrable mode [airflow]

VladaZakharova commented on PR #36108: URL: https://github.com/apache/airflow/pull/36108#issuecomment-1851762169 Hi Team! @eladkal @potiuk @hussein-awala Could you please check this PR? Thank you! -- This is an automated message from the Apache Git Service. To respond to the message,

Re: [PR] Add ability to run streaming Job for BeamRunPythonPipelineOperator in non deferrable mode [airflow]

potiuk merged PR #36108: URL: https://github.com/apache/airflow/pull/36108 -- 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: commits-unsubscr...@airflow.a