Hi
after i did “pip install apache-airflow-providers-mysql”
i cant start the scheduler and webserver anymore…
i get these exceptions :
/home/aflow/.local/lib/python3.6/site-packages/airflow/configuration.py:269: FutureWarning: The hostname_callable setting in [core] has the old default value of ‘socket:getfqdn’. This value has been changed to ‘socket.getfqdn’ in the running config, but please update your config before Apache Airflow 2.1.
FutureWarning,
/home/aflow/.local/lib/python3.6/site-packages/airflow/configuration.py:269: FutureWarning: The navbar_color setting in [webserver] has the old default value of ‘#007A87’. This value has been changed to ‘#fff’ in the running config, but please update your config before Apache Airflow 2.1.
FutureWarning,
/home/aflow/.local/lib/python3.6/site-packages/airflow/configuration.py:324: DeprecationWarning: The log_format option in [core] has been moved to the log_format option in [logging] - the old setting has been used, but please update your config.
option = self._get_option_from_config_file(deprecated_key, deprecated_section, key, kwargs, section)
/home/aflow/.local/lib/python3.6/site-packages/airflow/configuration.py:324: DeprecationWarning: The simple_log_format option in [core] has been moved to the simple_log_format option in [logging] - the old setting has been used, but please update your config.
option = self._get_option_from_config_file(deprecated_key, deprecated_section, key, kwargs, section)
/home/aflow/.local/lib/python3.6/site-packages/airflow/configuration.py:324 DeprecationWarning: The logging_config_class option in [core] has been moved to the logging_config_class option in [logging] - the old setting has been used, but please update your config.
/home/aflow/.local/lib/python3.6/site-packages/airflow/configuration.py:324 DeprecationWarning: The logging_level option in [core] has been moved to the logging_level option in [logging] - the old setting has been used, but please update your config.
/home/aflow/.local/lib/python3.6/site-packages/airflow/configuration.py:324 DeprecationWarning: The fab_logging_level option in [core] has been moved to the fab_logging_level option in [logging] - the old setting has been used, but please update your config.
/home/aflow/.local/lib/python3.6/site-packages/airflow/configuration.py:324 DeprecationWarning: The colored_log_format option in [core] has been moved to the colored_log_format option in [logging] - the old setting has been used, but please update your config.
/home/aflow/.local/lib/python3.6/site-packages/airflow/configuration.py:324 DeprecationWarning: The colored_console_log option in [core] has been moved to the colored_console_log option in [logging] - the old setting has been used, but please update your config.
/home/aflow/.local/lib/python3.6/site-packages/airflow/configuration.py:324 DeprecationWarning: The colored_formatter_class option in [core] has been moved to the colored_formatter_class option in [logging] - the old setting has been used, but please update your config.
/home/aflow/.local/lib/python3.6/site-packages/airflow/configuration.py:324 DeprecationWarning: The base_log_folder option in [core] has been moved to the base_log_folder option in [logging] - the old setting has been used, but please update your config.
/home/aflow/.local/lib/python3.6/site-packages/airflow/configuration.py:324 DeprecationWarning: The dag_processor_manager_log_location option in [core] has been moved to the dag_processor_manager_log_location option in [logging] - the old setting has been used, but please update your config.
/home/aflow/.local/lib/python3.6/site-packages/airflow/configuration.py:324 DeprecationWarning: The log_filename_template option in [core] has been moved to the log_filename_template option in [logging] - the old setting has been used, but please update your config.
/home/aflow/.local/lib/python3.6/site-packages/airflow/configuration.py:324 DeprecationWarning: The log_processor_filename_template option in [core] has been moved to the log_processor_filename_template option in [logging] - the old setting has been used, but please update your config.
/home/aflow/.local/lib/python3.6/site-packages/airflow/configuration.py:324 DeprecationWarning: The remote_logging option in [core] has been moved to the remote_logging option in [logging] - the old setting has been used, but please update your config.
/home/aflow/.local/lib/python3.6/site-packages/airflow/configuration.py:324 DeprecationWarning: The task_log_reader option in [core] has been moved to the task_log_reader option in [logging] - the old setting has been used, but please update your config.
/home/aflow/.local/lib/python3.6/site-packages/airflow/configuration.py:324 DeprecationWarning: The statsd_on option in [scheduler] has been moved to the statsd_on option in [metrics] - the old setting has been used, but please update your config.
____ |( )_______ / /________ __
____ /| |_ /__ / / __ / __ _ | /| / /
___ ___ | / _ / _ / _ / / // / |/ |/ /
// |// // // // _/____/|__/
[2021-01-26 18:02:28,034] {scheduler_job.py:1241} INFO - Starting the scheduler
[2021-01-26 18:02:28,034] {scheduler_job.py:1246} INFO - Processing each file at most -1 times
[2021-01-26 18:02:28,147] {dag_processing.py:250} INFO - Launched DagFileProcessorManager with pid: 15917
[2021-01-26 18:02:28,148] {scheduler_job.py:1751} INFO - Resetting orphaned tasks for active dag runs
[2021-01-26 18:02:28,174] {scheduler_job.py:1764} INFO - Marked 21 SchedulerJob instances as failed
[2021-01-26 18:02:28,184] {scheduler_job.py:1293} ERROR - Exception when executing SchedulerJob._run_scheduler_loop
Traceback (most recent call last):
File “/home/aflow/.local/lib/python3.6/site-packages/sqlalchemy/engine/base.py”, line 1277, in _execute_context
cursor, statement, parameters, context
File “/home/aflow/.local/lib/python3.6/site-packages/sqlalchemy/engine/default.py”, line 609, in do_execute
cursor.execute(statement, parameters)
psycopg2.errors.SyntaxError: syntax error at or near “SKIP”
LINE 3: …run.state = ‘running’ FOR UPDATE OF task_instance SKIP LOCKE…
^
The above exception was the direct cause of the following exception:
Traceback (most recent call last):
File “/home/aflow/.local/lib/python3.6/site-packages/airflow/jobs/scheduler_job.py”, line 1275, in _execute
self._run_scheduler_loop()
File “/home/aflow/.local/lib/python3.6/site-packages/airflow/jobs/scheduler_job.py”, line 1349, in _run_scheduler_loop
self.adopt_or_reset_orphaned_tasks()
File “/home/aflow/.local/lib/python3.6/site-packages/airflow/utils/session.py”, line 65, in wrapper
return func(*args, session=session, **kwargs)
File “/home/aflow/.local/lib/python3.6/site-packages/airflow/jobs/scheduler_job.py”, line 1787, in adopt_or_reset_orphaned_tasks
tis_to_reset_or_adopt = with_row_locks(query, of=TI, **skip_locked(session=session)).all()
File “/home/aflow/.local/lib/python3.6/site-packages/sqlalchemy/orm/query.py”, line 3373, in all
return list(self)
File “/home/aflow/.local/lib/python3.6/site-packages/sqlalchemy/orm/query.py”, line 3535, in iter
return self._execute_and_instances(context)
File “/home/aflow/.local/lib/python3.6/site-packages/sqlalchemy/orm/query.py”, line 3560, in _execute_and_instances
result = conn.execute(querycontext.statement, self._params)
File “/home/aflow/.local/lib/python3.6/site-packages/sqlalchemy/engine/base.py”, line 1011, in execute
return meth(self, multiparams, params)
File “/home/aflow/.local/lib/python3.6/site-packages/sqlalchemy/sql/elements.py”, line 298, in _execute_on_connection
return connection._execute_clauseelement(self, multiparams, params)
File “/home/aflow/.local/lib/python3.6/site-packages/sqlalchemy/engine/base.py”, line 1130, in _execute_clauseelement
distilled_params,
File “/home/aflow/.local/lib/python3.6/site-packages/sqlalchemy/engine/base.py”, line 1317, in execute_context
e, statement, parameters, cursor, context
File “/home/aflow/.local/lib/python3.6/site-packages/sqlalchemy/engine/base.py”, line 1511, in handle_dbapi_exception
sqlalchemy_exception, with_traceback=exc_info[2], from=e
File “/home/aflow/.local/lib/python3.6/site-packages/sqlalchemy/util/compat.py”, line 182, in raise
raise exception
File “/home/aflow/.local/lib/python3.6/site-packages/sqlalchemy/engine/base.py”, line 1277, in _execute_context
cursor, statement, parameters, context
File “/home/aflow/.local/lib/python3.6/site-packages/sqlalchemy/engine/default.py”, line 609, in do_execute
cursor.execute(statement, parameters)
sqlalchemy.exc.ProgrammingError: (psycopg2.errors.SyntaxError) syntax error at or near “SKIP”
LINE 3: …run.state = ‘running’ FOR UPDATE OF task_instance SKIP LOCKE…
^
[SQL: SELECT task_instance.task_id AS task_instance_task_id, task_instance.dag_id AS task_instance_dag_id, task_instance.execution_date AS task_instance_execution_date
FROM task_instance LEFT OUTER JOIN job ON task_instance.queued_by_job_id = job.id JOIN dag_run ON task_instance.dag_id = dag_run.dag_id AND task_instance.execution_date = dag_run.execution_date
WHERE task_instance.state IN (%(state_1)s, %(state_2)s, %(state_3)s) AND (task_instance.queued_by_job_id IS NULL OR job.state != %(state_4)s) AND dag_run.run_type != %(run_type_1)s AND dag_run.state = %(state_5)s FOR UPDATE OF task_instance SKIP LOCKED]
[parameters: {‘state_1’: ‘scheduled’, ‘state_2’: ‘queued’, ‘state_3’: ‘running’, ‘state_4’: ‘running’, ‘run_type_1’: <DagRunType.BACKFILL_JOB: ‘backfill’>, ‘state_5’: ‘running’}]
(Background on this error at: http://sqlalche.me/e/13/f405)
/home/aflow/.local/lib/python3.6/site-packages/airflow/configuration.py:324 DeprecationWarning: The logging_level option in [core] has been moved to the logging_level option in [logging] - the old setting has been used, but please update your config.
/home/aflow/.local/lib/python3.6/site-packages/airflow/configuration.py:324 DeprecationWarning: The fab_logging_level option in [core] has been moved to the fab_logging_level option in [logging] - the old setting has been used, but please update your config.
/home/aflow/.local/lib/python3.6/site-packages/airflow/configuration.py:324 DeprecationWarning: The log_format option in [core] has been moved to the log_format option in [logging] - the old setting has been used, but please update your config.
/home/aflow/.local/lib/python3.6/site-packages/airflow/configuration.py:324 DeprecationWarning: The colored_log_format option in [core] has been moved to the colored_log_format option in [logging] - the old setting has been used, but please update your config.
/home/aflow/.local/lib/python3.6/site-packages/airflow/configuration.py:324 DeprecationWarning: The colored_formatter_class option in [core] has been moved to the colored_formatter_class option in [logging] - the old setting has been used, but please update your config.
/home/aflow/.local/lib/python3.6/site-packages/airflow/configuration.py:324 DeprecationWarning: The base_log_folder option in [core] has been moved to the base_log_folder option in [logging] - the old setting has been used, but please update your config.
/home/aflow/.local/lib/python3.6/site-packages/airflow/configuration.py:324 DeprecationWarning: The dag_processor_manager_log_location option in [core] has been moved to the dag_processor_manager_log_location option in [logging] - the old setting has been used, but please update your config.
/home/aflow/.local/lib/python3.6/site-packages/airflow/configuration.py:324 DeprecationWarning: The log_filename_template option in [core] has been moved to the log_filename_template option in [logging] - the old setting has been used, but please update your config.
/home/aflow/.local/lib/python3.6/site-packages/airflow/configuration.py:324 DeprecationWarning: The log_processor_filename_template option in [core] has been moved to the log_processor_filename_template option in [logging] - the old setting has been used, but please update your config.
/home/aflow/.local/lib/python3.6/site-packages/airflow/configuration.py:324 DeprecationWarning: The remote_logging option in [core] has been moved to the remote_logging option in [logging] - the old setting has been used, but please update your config.
[2021-01-26 18:02:28,223] {settings.py:52} INFO - Configured default timezone Timezone(‘UTC’)
/home/aflow/.local/lib/python3.6/site-packages/airflow/configuration.py:324 DeprecationWarning: The simple_log_format option in [core] has been moved to the simple_log_format option in [logging] - the old setting has been used, but please update your config.
/home/aflow/.local/lib/python3.6/site-packages/airflow/configuration.py:324 DeprecationWarning: The logging_config_class option in [core] has been moved to the logging_config_class option in [logging] - the old setting has been used, but please update your config.
/home/aflow/.local/lib/python3.6/site-packages/airflow/configuration.py:324 DeprecationWarning: The task_log_reader option in [core] has been moved to the task_log_reader option in [logging] - the old setting has been used, but please update your config.
/home/aflow/.local/lib/python3.6/site-packages/airflow/configuration.py:324 DeprecationWarning: The max_threads option in [scheduler] has been renamed to parsing_processes - the old setting has been used, but please update your config.
Process ForkProcess-34:
Traceback (most recent call last):
File “/home/aflow/.local/lib/python3.6/site-packages/sqlalchemy/engine/base.py”, line 1277, in _execute_context
cursor, statement, parameters, context
File “/home/aflow/.local/lib/python3.6/site-packages/sqlalchemy/engine/default.py”, line 609, in do_execute
cursor.execute(statement, parameters)
psycopg2.errors.UndefinedColumn: column dag.concurrency does not exist
LINE 1: …, dag.schedule_interval AS dag_schedule_interval, dag.concur…
^
The above exception was the direct cause of the following exception:
Traceback (most recent call last):
File “/usr/lib64/python3.6/multiprocessing/process.py”, line 258, in _bootstrap
self.run()
File “/usr/lib64/python3.6/multiprocessing/process.py”, line 93, in run
self._target(*self._args, **self._kwargs)
File “/home/aflow/.local/lib/python3.6/site-packages/airflow/utils/dag_processing.py”, line 365, in _run_processor_manager
processor_manager.start()
File “/home/aflow/.local/lib/python3.6/site-packages/airflow/utils/dag_processing.py”, line 596, in start
return self._run_parsing_loop()
File “/home/aflow/.local/lib/python3.6/site-packages/airflow/utils/dag_processing.py”, line 606, in _run_parsing_loop
self._refresh_dag_dir()
File “/home/aflow/.local/lib/python3.6/site-packages/airflow/utils/dag_processing.py”, line 739, in _refresh_dag_dir
DagModel.deactivate_deleted_dags(self._file_paths)
File “/home/aflow/.local/lib/python3.6/site-packages/airflow/utils/session.py”, line 65, in wrapper
return func(*args, session=session, **kwargs)
File “/home/aflow/.local/lib/python3.6/site-packages/airflow/models/dag.py”, line 2201, in deactivate_deleted_dags
dag_models = session.query(cls).all()
File “/home/aflow/.local/lib/python3.6/site-packages/sqlalchemy/orm/query.py”, line 3373, in all
return list(self)
File “/home/aflow/.local/lib/python3.6/site-packages/sqlalchemy/orm/query.py”, line 3535, in iter
return self._execute_and_instances(context)
File “/home/aflow/.local/lib/python3.6/site-packages/sqlalchemy/orm/query.py”, line 3560, in _execute_and_instances
result = conn.execute(querycontext.statement, self._params)
File “/home/aflow/.local/lib/python3.6/site-packages/sqlalchemy/engine/base.py”, line 1011, in execute
return meth(self, multiparams, params)
File “/home/aflow/.local/lib/python3.6/site-packages/sqlalchemy/sql/elements.py”, line 298, in _execute_on_connection
return connection._execute_clauseelement(self, multiparams, params)
File “/home/aflow/.local/lib/python3.6/site-packages/sqlalchemy/engine/base.py”, line 1130, in _execute_clauseelement
distilled_params,
File “/home/aflow/.local/lib/python3.6/site-packages/sqlalchemy/engine/base.py”, line 1317, in execute_context
e, statement, parameters, cursor, context
File “/home/aflow/.local/lib/python3.6/site-packages/sqlalchemy/engine/base.py”, line 1511, in handle_dbapi_exception
sqlalchemy_exception, with_traceback=exc_info[2], from=e
File “/home/aflow/.local/lib/python3.6/site-packages/sqlalchemy/util/compat.py”, line 182, in raise
raise exception
File “/home/aflow/.local/lib/python3.6/site-packages/sqlalchemy/engine/base.py”, line 1277, in _execute_context
cursor, statement, parameters, context
File “/home/aflow/.local/lib/python3.6/site-packages/sqlalchemy/engine/default.py”, line 609, in do_execute
cursor.execute(statement, parameters)
sqlalchemy.exc.ProgrammingError: (psycopg2.errors.UndefinedColumn) column dag.concurrency does not exist
LINE 1: …, dag.schedule_interval AS dag_schedule_interval, dag.concur…
^
[SQL: SELECT dag.dag_id AS dag_dag_id, dag.root_dag_id AS dag_root_dag_id, dag.is_paused AS dag_is_paused, dag.is_subdag AS dag_is_subdag, dag.is_active AS dag_is_active, dag.last_scheduler_run AS dag_last_scheduler_run, dag.last_pickled AS dag_last_pickled, dag.last_expired AS dag_last_expired, dag.scheduler_lock AS dag_scheduler_lock, dag.pickle_id AS dag_pickle_id, dag.fileloc AS dag_fileloc, dag.owners AS dag_owners, dag.description AS dag_description, dag.default_view AS dag_default_view, dag.schedule_interval AS dag_schedule_interval, dag.concurrency AS dag_concurrency, dag.has_task_concurrency_limits AS dag_has_task_concurrency_limits, dag.next_dagrun AS dag_next_dagrun, dag.next_dagrun_create_after AS dag_next_dagrun_create_after
FROM dag]
(Background on this error at: http://sqlalche.me/e/13/f405)
[2021-01-26 18:02:28,309] {process_utils.py:95} INFO - Sending Signals.SIGTERM to GPID 15917
[2021-01-26 18:02:28,309] {scheduler_job.py:1296} INFO - Exited execute loop
Process QueuedLocalWorker-14:
Process QueuedLocalWorker-5:
Traceback (most recent call last):
File “/usr/lib64/python3.6/multiprocessing/process.py”, line 258, in _bootstrap
self.run()
File “/home/aflow/.local/lib/python3.6/site-packages/airflow/executors/local_executor.py”, line 69, in run
return super().run()
File “/usr/lib64/python3.6/multiprocessing/process.py”, line 93, in run
self._target(*self._args, **self._kwargs)
File “/home/aflow/.local/lib/python3.6/site-packages/airflow/executors/local_executor.py”, line 176, in do_work
key, command = self.task_queue.get()
File “”, line 2, in get
File “/usr/lib64/python3.6/multiprocessing/managers.py”, line 757, in _callmethod
kind, result = conn.recv()
File “/usr/lib64/python3.6/multiprocessing/connection.py”, line 250, in recv
buf = self._recv_bytes()
File “/usr/lib64/python3.6/multiprocessing/connection.py”, line 407, in _recv_bytes
buf = self._recv(4)
File “/usr/lib64/python3.6/multiprocessing/connection.py”, line 383, in _recv
raise EOFError
EOFError
Traceback (most recent call last):
File “/usr/lib64/python3.6/multiprocessing/process.py”, line 258, in _bootstrap
self.run()
File “/home/aflow/.local/lib/python3.6/site-packages/airflow/executors/local_executor.py”, line 69, in run
return super().run()
File “/usr/lib64/python3.6/multiprocessing/process.py”, line 93, in run
self._target(*self._args, **self._kwargs)
File “/home/aflow/.local/lib/python3.6/site-packages/airflow/executors/local_executor.py”, line 176, in do_work
key, command = self.task_queue.get()
File “”, line 2, in get
File “/usr/lib64/python3.6/multiprocessing/managers.py”, line 757, in _callmethod
kind, result = conn.recv()
File “/usr/lib64/python3.6/multiprocessing/connection.py”, line 250, in recv
buf = self._recv_bytes()
File “/usr/lib64/python3.6/multiprocessing/connection.py”, line 407, in _recv_bytes
buf = self._recv(4)
File “/usr/lib64/python3.6/multiprocessing/connection.py”, line 383, in _recv
raise EOFError
EOFError
Process QueuedLocalWorker-2:
Process QueuedLocalWorker-27:
Traceback (most recent call last):
File “/usr/lib64/python3.6/multiprocessing/process.py”, line 258, in _bootstrap
self.run()
File “/home/aflow/.local/lib/python3.6/site-packages/airflow/executors/local_executor.py”, line 69, in run
return super().run()
File “/usr/lib64/python3.6/multiprocessing/process.py”, line 93, in run
self._target(*self._args, **self._kwargs)
File “/home/aflow/.local/lib/python3.6/site-packages/airflow/executors/local_executor.py”, line 176, in do_work
key, command = self.task_queue.get()
File “”, line 2, in get
File “/usr/lib64/python3.6/multiprocessing/managers.py”, line 757, in _callmethod
kind, result = conn.recv()
File “/usr/lib64/python3.6/multiprocessing/connection.py”, line 250, in recv
buf = self._recv_bytes()
File “/usr/lib64/python3.6/multiprocessing/connection.py”, line 407, in _recv_bytes
buf = self._recv(4)
File “/usr/lib64/python3.6/multiprocessing/connection.py”, line 383, in _recv
raise EOFError
EOFError
Traceback (most recent call last):
File “/usr/lib64/python3.6/multiprocessing/process.py”, line 258, in _bootstrap
self.run()
File “/home/aflow/.local/lib/python3.6/site-packages/airflow/executors/local_executor.py”, line 69, in run
return super().run()
File “/usr/lib64/python3.6/multiprocessing/process.py”, line 93, in run
self._target(*self._args, **self._kwargs)
File “/home/aflow/.local/lib/python3.6/site-packages/airflow/executors/local_executor.py”, line 176, in do_work
key, command = self.task_queue.get()
File “”, line 2, in get
File “/usr/lib64/python3.6/multiprocessing/managers.py”, line 757, in _callmethod
kind, result = conn.recv()
File “/usr/lib64/python3.6/multiprocessing/connection.py”, line 250, in recv
buf = self._recv_bytes()
File “/usr/lib64/python3.6/multiprocessing/connection.py”, line 407, in _recv_bytes
buf = self._recv(4)
File “/usr/lib64/python3.6/multiprocessing/connection.py”, line 383, in _recv
raise EOFError
EOFError
Process QueuedLocalWorker-9:
Traceback (most recent call last):
File “/usr/lib64/python3.6/multiprocessing/process.py”, line 258, in _bootstrap
self.run()
File “/home/aflow/.local/lib/python3.6/site-packages/airflow/executors/local_executor.py”, line 69, in run
return super().run()
File “/usr/lib64/python3.6/multiprocessing/process.py”, line 93, in run
self._target(*self._args, **self._kwargs)
File “/home/aflow/.local/lib/python3.6/site-packages/airflow/executors/local_executor.py”, line 176, in do_work
key, command = self.task_queue.get()
File “”, line 2, in get
File “/usr/lib64/python3.6/multiprocessing/managers.py”, line 757, in _callmethod
kind, result = conn.recv()
File “/usr/lib64/python3.6/multiprocessing/connection.py”, line 250, in recv
buf = self._recv_bytes()
File “/usr/lib64/python3.6/multiprocessing/connection.py”, line 407, in _recv_bytes
buf = self._recv(4)
File “/usr/lib64/python3.6/multiprocessing/connection.py”, line 383, in _recv
raise EOFError
EOFError
Process QueuedLocalWorker-23:
Traceback (most recent call last):
File “/usr/lib64/python3.6/multiprocessing/process.py”, line 258, in _bootstrap
self.run()
File “/home/aflow/.local/lib/python3.6/site-packages/airflow/executors/local_executor.py”, line 69, in run
return super().run()
File “/usr/lib64/python3.6/multiprocessing/process.py”, line 93, in run
self._target(*self._args, **self._kwargs)
File “/home/aflow/.local/lib/python3.6/site-packages/airflow/executors/local_executor.py”, line 176, in do_work
key, command = self.task_queue.get()
File “”, line 2, in get
File “/usr/lib64/python3.6/multiprocessing/managers.py”, line 757, in _callmethod
kind, result = conn.recv()
File “/usr/lib64/python3.6/multiprocessing/connection.py”, line 250, in recv
buf = self._recv_bytes()
File “/usr/lib64/python3.6/multiprocessing/connection.py”, line 407, in _recv_bytes
buf = self._recv(4)
File “/usr/lib64/python3.6/multiprocessing/connection.py”, line 383, in _recv
raise EOFError
EOFError
Process QueuedLocalWorker-7:
Traceback (most recent call last):
File “/usr/lib64/python3.6/multiprocessing/process.py”, line 258, in _bootstrap
self.run()
File “/home/aflow/.local/lib/python3.6/site-packages/airflow/executors/local_executor.py”, line 69, in run
return super().run()
File “/usr/lib64/python3.6/multiprocessing/process.py”, line 93, in run
self._target(*self._args, **self._kwargs)
File “/home/aflow/.local/lib/python3.6/site-packages/airflow/executors/local_executor.py”, line 176, in do_work
key, command = self.task_queue.get()
File “”, line 2, in get
File “/usr/lib64/python3.6/multiprocessing/managers.py”, line 757, in _callmethod
kind, result = conn.recv()
File “/usr/lib64/python3.6/multiprocessing/connection.py”, line 250, in recv
buf = self._recv_bytes()
File “/usr/lib64/python3.6/multiprocessing/connection.py”, line 407, in _recv_bytes
buf = self._recv(4)
File “/usr/lib64/python3.6/multiprocessing/connection.py”, line 383, in _recv
raise EOFError
EOFError
Exception ignored in: <bound method _ConnectionBase.del of <multiprocessing.connection.Connection object at 0x7f2a2449cf98>>
Traceback (most recent call last):
File “/usr/lib64/python3.6/multiprocessing/connection.py”, line 130, in del
Process QueuedLocalWorker-6:
def del(self):
File “/home/aflow/.local/lib/python3.6/site-packages/airflow/utils/cli.py”, line 253, in sigint_handler
sys.exit(0)
SystemExit: 0
Process QueuedLocalWorker-10:
Process QueuedLocalWorker-29:
Process QueuedLocalWorker-15:
Process QueuedLocalWorker-33:
Process QueuedLocalWorker-17:
Process QueuedLocalWorker-32:
Process QueuedLocalWorker-21:
Process QueuedLocalWorker-31:
Process QueuedLocalWorker-16:
Process QueuedLocalWorker-28:
Process QueuedLocalWorker-4:
Process QueuedLocalWorker-25:
Process QueuedLocalWorker-13:
Process QueuedLocalWorker-30:
Process QueuedLocalWorker-12:
Process QueuedLocalWorker-24:
Process QueuedLocalWorker-3:
Process QueuedLocalWorker-26:
Process QueuedLocalWorker-18:
Process QueuedLocalWorker-22:
Process QueuedLocalWorker-11:
Process QueuedLocalWorker-20:
Process QueuedLocalWorker-8:
Process QueuedLocalWorker-19:
please help