mhenc commented on a change in pull request #22305:
URL: https://github.com/apache/airflow/pull/22305#discussion_r832605958
##########
File path: airflow/dag_processing/manager.py
##########
@@ -383,14 +383,15 @@ def __init__(
self._dag_ids = dag_ids
self._async_mode = async_mode
self._parsing_start_time: Optional[int] = None
+ self._standalone_mode = conf.getboolean("scheduler",
"standalone_dag_processor")
# Set the signal conn in to non-blocking mode, so that attempting to
# send when the buffer is full errors, rather than hangs for-ever
# attempting to send (this is to avoid deadlocks!)
#
# Don't do this in sync_mode, as we _need_ the DagParsingStat sent to
# continue the scheduler
- if self._async_mode:
+ if self._async_mode and not self._standalone_mode and
self._signal_conn is not None:
Review comment:
Makes sense, Removed _standalone_mode and rely only on _signal_conn
(actually renamed to _direct_scheduler_conn)
--
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]
