msumit opened a new pull request #11683:
URL: https://github.com/apache/airflow/pull/11683
Was getting the following error when running 2 schedulers and 1 scheduler
would die withing seconds after starting
> Traceback (most recent call last):
File
"/Users/smaheshwari/work/airflow/venv/lib/python3.7/site-packages/airflow/jobs/scheduler_job.py",
line 1316, in _execute
self._run_scheduler_loop()
File
"/Users/smaheshwari/work/airflow/venv/lib/python3.7/site-packages/airflow/jobs/scheduler_job.py",
line 1389, in _run_scheduler_loop
num_queued_tis = self._do_scheduling(session)
File
"/Users/smaheshwari/work/airflow/venv/lib/python3.7/site-packages/airflow/jobs/scheduler_job.py",
line 1513, in _do_scheduling
session=session
File
"/Users/smaheshwari/work/airflow/venv/lib/python3.7/site-packages/airflow/utils/session.py",
line 61, in wrapper
return func(*args, **kwargs)
File
"/Users/smaheshwari/work/airflow/venv/lib/python3.7/site-packages/airflow/jobs/scheduler_job.py",
line 860, in _change_state_for_tis_without_dagrun
tis_to_change: List[TI] = with_row_locks(query).all()
.....
.....
sqlalchemy.exc.OperationalError: (pymysql.err.OperationalError) (1213,
'Deadlock found when trying to get lock; try restarting
transaction')
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
[email protected]
