utkarsharma2 commented on code in PR #28934: URL: https://github.com/apache/airflow/pull/28934#discussion_r1082578543
########## airflow/cli/commands/standalone_command.py: ########## @@ -159,14 +159,28 @@ def calculate_env(self): # Make sure we're using a local executor flavour executor_class, _ = ExecutorLoader.import_default_executor_cls() if not executor_class.is_local: - if "sqlite" in conf.get("database", "sql_alchemy_conn"): - self.print_output("standalone", "Forcing executor to SequentialExecutor") - env["AIRFLOW__CORE__EXECUTOR"] = executor_constants.SEQUENTIAL_EXECUTOR - else: - self.print_output("standalone", "Forcing executor to LocalExecutor") - env["AIRFLOW__CORE__EXECUTOR"] = executor_constants.LOCAL_EXECUTOR + env["AIRFLOW__CORE__EXECUTOR"] = self.get_local_executor( + database=conf.get("database", "sql_alchemy_conn") + ) + self.print_output("standalone", f"Forcing executor to {env['AIRFLOW__CORE__EXECUTOR']}") Review Comment: @o-nikolas The only benefit I see with this code we still remove the need to change this part of the code if someone implements a new local executor, right? -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org