[2023-08-11 17:05:54,363] {process_utils.py:133} INFO - Sending Signals.SIGTERM to group 27657. PIDs of all processes in the group: [27708, 27710, 27657]
[2023-08-11 17:05:54,363] {process_utils.py:84} INFO - Sending the signal Signals.SIGTERM to group 27657
[2023-08-11 17:05:55,069] {process_utils.py:79} INFO - Process psutil.Process(pid=27710, status='terminated', started='17:05:53') (27710) terminated with exit code None
[2023-08-11 17:05:55,070] {process_utils.py:79} INFO - Process psutil.Process(pid=27708, status='terminated', started='17:05:53') (27708) terminated with exit code None
[2023-08-11T11:35:55.109+0000] {process_utils.py:256} INFO - Waiting up to 5 seconds for processes to exit...
[2023-08-11 17:05:55,202] {process_utils.py:79} INFO - Process psutil.Process(pid=27657, status='terminated', exitcode=0, started='17:05:52') (27657) terminated with exit code 0
[2023-08-11 17:05:55,203] {scheduler_job.py:775} INFO - Exited execute loop
[2023-08-11 17:05:55 +0530] [27626] [INFO] Handling signal: term
[2023-08-11 17:05:55 +0530] [27627] [INFO] Worker exiting (pid: 27627)
[2023-08-11 17:05:55 +0530] [27661] [INFO] Worker exiting (pid: 27661)
Traceback (most recent call last):
File "/home/hobapp/.local/bin/airflow", line 8, in <module>
sys.exit(main())
File "/home/hobapp/.local/lib/python3.7/site-packages/airflow/__main__.py", line 39, in main
args.func(args)
File "/home/hobapp/.local/lib/python3.7/site-packages/airflow/cli/cli_parser.py", line 52, in command
return func(*args, **kwargs)
File "/home/hobapp/.local/lib/python3.7/site-packages/airflow/utils/cli.py", line 99, in wrapper
return f(*args, **kwargs)
File "/home/hobapp/.local/lib/python3.7/site-packages/airflow/cli/commands/scheduler_command.py", line 85, in scheduler
_run_scheduler_job(args=args)
File "/home/hobapp/.local/lib/python3.7/site-packages/airflow/cli/commands/scheduler_command.py", line 50, in _run_scheduler_job
job.run()
File "/home/hobapp/.local/lib/python3.7/site-packages/airflow/jobs/base_job.py", line 247, in run
self._execute()
File "/home/hobapp/.local/lib/python3.7/site-packages/airflow/jobs/scheduler_job.py", line 746, in _execute
self._run_scheduler_loop()
File "/home/hobapp/.local/lib/python3.7/site-packages/airflow/jobs/scheduler_job.py", line 866, in _run_scheduler_loop
num_queued_tis = self._do_scheduling(session)
File "/home/hobapp/.local/lib/python3.7/site-packages/airflow/jobs/scheduler_job.py", line 947, in _do_scheduling
for dag_run in dag_runs:
File "/home/hobapp/.local/lib/python3.7/site-packages/sqlalchemy/engine/result.py", line 369, in iterrows
for row in self._fetchiter_impl():
File "/home/hobapp/.local/lib/python3.7/site-packages/sqlalchemy/orm/loading.py", line 147, in chunks
fetch = cursor._raw_all_rows()
File "/home/hobapp/.local/lib/python3.7/site-packages/sqlalchemy/engine/result.py", line 393, in _raw_all_rows
return [make_row(row) for row in rows]
File "/home/hobapp/.local/lib/python3.7/site-packages/sqlalchemy/engine/result.py", line 393, in <listcomp>
return [make_row(row) for row in rows]
File "/home/hobapp/.local/lib/python3.7/site-packages/sqlalchemy/sql/sqltypes.py", line 1870, in process
return loads(value)
ValueError: unsupported pickle protocol: 5
[2023-08-11 17:05:55 +0530] [27626] [INFO] Shutting down: Master