deepaktripathi1997 commented on issue #37657:
URL: https://github.com/apache/airflow/issues/37657#issuecomment-1961920994

   @potiuk 
   Still getting the same issue
   2024-02-23T20:01:52.726Z | (Background on this error at: 
https://sqlalche.me/e/14/e3q8) (Background on this error at: 
https://sqlalche.me/e/14/7s2a)
   2024-02-23T20:01:52.729Z | Traceback (most recent call last):
   2024-02-23T20:01:52.729Z |   File "/home/airflow/.local/bin/airflow", line 
8, in <module>
   2024-02-23T20:01:52.729Z |     sys.exit(main())
   2024-02-23T20:01:52.729Z |   File 
"/home/airflow/.local/lib/python3.8/site-packages/airflow/__main__.py", line 
57, in main
   2024-02-23T20:01:52.729Z |     args.func(args)
   2024-02-23T20:01:52.729Z |   File 
"/home/airflow/.local/lib/python3.8/site-packages/airflow/cli/cli_config.py", 
line 49, in command
   2024-02-23T20:01:52.729Z |     return func(*args, **kwargs)
   2024-02-23T20:01:52.729Z |   File 
"/home/airflow/.local/lib/python3.8/site-packages/airflow/utils/cli.py", line 
114, in wrapper
   2024-02-23T20:01:52.729Z |     return f(*args, **kwargs)
   2024-02-23T20:01:52.729Z |   File 
"/home/airflow/.local/lib/python3.8/site-packages/airflow/utils/providers_configuration_loader.py",
 line 55, in wrapped_function
   2024-02-23T20:01:52.729Z |     return func(*args, **kwargs)
   2024-02-23T20:01:52.729Z |   File 
"/home/airflow/.local/lib/python3.8/site-packages/airflow/cli/commands/scheduler_command.py",
 line 67, in scheduler
   2024-02-23T20:01:52.729Z |     run_command_with_daemon_option(
   2024-02-23T20:01:52.729Z |   File 
"/home/airflow/.local/lib/python3.8/site-packages/airflow/cli/commands/daemon_utils.py",
 line 86, in run_command_with_daemon_option
   2024-02-23T20:01:52.729Z |     callback()
   2024-02-23T20:01:52.729Z |   File 
"/home/airflow/.local/lib/python3.8/site-packages/airflow/cli/commands/scheduler_command.py",
 line 70, in <lambda>
   2024-02-23T20:01:52.729Z |     callback=lambda: _run_scheduler_job(args),
   2024-02-23T20:01:52.729Z |   File 
"/home/airflow/.local/lib/python3.8/site-packages/airflow/cli/commands/scheduler_command.py",
 line 52, in _run_scheduler_job
   2024-02-23T20:01:52.729Z |     run_job(job=job_runner.job, 
execute_callable=job_runner._execute)
   2024-02-23T20:01:52.729Z |   File 
"/home/airflow/.local/lib/python3.8/site-packages/airflow/utils/session.py", 
line 79, in wrapper
   2024-02-23T20:01:52.729Z |     return func(*args, session=session, **kwargs)
   2024-02-23T20:01:52.729Z |   File 
"/home/airflow/.local/lib/python3.8/site-packages/airflow/jobs/job.py", line 
393, in run_job
   2024-02-23T20:01:52.729Z |     return execute_job(job, 
execute_callable=execute_callable)
   2024-02-23T20:01:52.729Z |   File 
"/home/airflow/.local/lib/python3.8/site-packages/airflow/jobs/job.py", line 
422, in execute_job
   2024-02-23T20:01:52.729Z |     ret = execute_callable()
   2024-02-23T20:01:52.729Z |   File 
"/home/airflow/.local/lib/python3.8/site-packages/airflow/jobs/scheduler_job_runner.py",
 line 855, in _execute
   2024-02-23T20:01:52.729Z |     self._run_scheduler_loop()
   2024-02-23T20:01:52.729Z |   File 
"/home/airflow/.local/lib/python3.8/site-packages/airflow/jobs/scheduler_job_runner.py",
 line 987, in _run_scheduler_loop
   2024-02-23T20:01:52.729Z |     num_queued_tis = self._do_scheduling(session)
   2024-02-23T20:01:52.729Z |   File 
"/home/airflow/.local/lib/python3.8/site-packages/airflow/jobs/scheduler_job_runner.py",
 line 1061, in _do_scheduling
   2024-02-23T20:01:52.729Z |     self._create_dagruns_for_dags(guard, session)
   2024-02-23T20:01:52.729Z |   File 
"/home/airflow/.local/lib/python3.8/site-packages/airflow/utils/retries.py", 
line 91, in wrapped_function
   2024-02-23T20:01:52.729Z |     for attempt in 
run_with_db_retries(max_retries=retries, logger=logger, **retry_kwargs):
   2024-02-23T20:01:52.729Z |   File 
"/home/airflow/.local/lib/python3.8/site-packages/tenacity/__init__.py", line 
347, in __iter__
   2024-02-23T20:01:52.729Z |     do = self.iter(retry_state=retry_state)
   2024-02-23T20:01:52.729Z |   File 
"/home/airflow/.local/lib/python3.8/site-packages/tenacity/__init__.py", line 
314, in iter
   2024-02-23T20:01:52.729Z |     return fut.result()
   2024-02-23T20:01:52.729Z |   File 
"/usr/local/lib/python3.8/concurrent/futures/_base.py", line 437, in result
   2024-02-23T20:01:52.729Z |     return self.__get_result()
   2024-02-23T20:01:52.729Z |   File 
"/usr/local/lib/python3.8/concurrent/futures/_base.py", line 389, in 
__get_result
   2024-02-23T20:01:52.729Z |     raise self._exception
   2024-02-23T20:01:52.729Z |   File 
"/home/airflow/.local/lib/python3.8/site-packages/airflow/utils/retries.py", 
line 100, in wrapped_function
   2024-02-23T20:01:52.729Z |     return func(*args, **kwargs)
   2024-02-23T20:01:52.729Z |   File 
"/home/airflow/.local/lib/python3.8/site-packages/airflow/jobs/scheduler_job_runner.py",
 line 1133, in _create_dagruns_for_dags
   2024-02-23T20:01:52.729Z |     self._create_dag_runs(non_dataset_dags, 
session)
   2024-02-23T20:01:52.729Z |   File 
"/home/airflow/.local/lib/python3.8/site-packages/airflow/jobs/scheduler_job_runner.py",
 line 1167, in _create_dag_runs
   2024-02-23T20:01:52.729Z |     dag = self.dagbag.get_dag(dag_model.dag_id, 
session=session)
   2024-02-23T20:01:52.729Z |   File 
"/home/airflow/.local/lib/python3.8/site-packages/sqlalchemy/orm/attributes.py",
 line 487, in __get__
   2024-02-23T20:01:52.729Z |     return self.impl.get(state, dict_)
   2024-02-23T20:01:52.729Z |   File 
"/home/airflow/.local/lib/python3.8/site-packages/sqlalchemy/orm/attributes.py",
 line 959, in get
   2024-02-23T20:01:52.729Z |     value = self._fire_loader_callables(state, 
key, passive)
   2024-02-23T20:01:52.729Z |   File 
"/home/airflow/.local/lib/python3.8/site-packages/sqlalchemy/orm/attributes.py",
 line 990, in _fire_loader_callables
   2024-02-23T20:01:52.729Z |     return state._load_expired(state, passive)
   2024-02-23T20:01:52.729Z |   File 
"/home/airflow/.local/lib/python3.8/site-packages/sqlalchemy/orm/state.py", 
line 712, in _load_expired
   2024-02-23T20:01:52.729Z |     self.manager.expired_attribute_loader(self, 
toload, passive)
   2024-02-23T20:01:52.729Z |   File 
"/home/airflow/.local/lib/python3.8/site-packages/sqlalchemy/orm/loading.py", 
line 1451, in load_scalar_attributes
   2024-02-23T20:01:52.729Z |     result = load_on_ident(
   2024-02-23T20:01:52.729Z |   File 
"/home/airflow/.local/lib/python3.8/site-packages/sqlalchemy/orm/loading.py", 
line 407, in load_on_ident
   2024-02-23T20:01:52.729Z |     return load_on_pk_identity(
   2024-02-23T20:01:52.729Z |   File 
"/home/airflow/.local/lib/python3.8/site-packages/sqlalchemy/orm/loading.py", 
line 530, in load_on_pk_identity
   2024-02-23T20:01:52.729Z |     session.execute(
   2024-02-23T20:01:52.729Z |   File 
"/home/airflow/.local/lib/python3.8/site-packages/sqlalchemy/orm/session.py", 
line 1716, in execute
   2024-02-23T20:01:52.729Z |     conn = self._connection_for_bind(bind)
   2024-02-23T20:01:52.729Z |   File 
"/home/airflow/.local/lib/python3.8/site-packages/sqlalchemy/orm/session.py", 
line 1555, in _connection_for_bind
   2024-02-23T20:01:52.729Z |     return self._transaction._connection_for_bind(
   2024-02-23T20:01:52.729Z |   File 
"/home/airflow/.local/lib/python3.8/site-packages/sqlalchemy/orm/session.py", 
line 724, in _connection_for_bind
   2024-02-23T20:01:52.729Z |     self._assert_active()
   2024-02-23T20:01:52.729Z |   File 
"/home/airflow/.local/lib/python3.8/site-packages/sqlalchemy/orm/session.py", 
line 604, in _assert_active
   2024-02-23T20:01:52.729Z |     raise sa_exc.PendingRollbackError(
   2024-02-23T20:01:52.729Z | sqlalchemy.exc.PendingRollbackError: This 
Session's transaction has been rolled back due to a previous exception during 
flush. To begin a new transaction with this Session, first issue 
Session.rollback(). Original exception was: (MySQLdb.OperationalError) (1213, 
'Deadlock found when trying to get lock; try restarting transaction')
   2024-02-23T20:01:52.729Z | [SQL: INSERT INTO dag_run (dag_id, queued_at, 
execution_date, start_date, end_date, state, run_id, creating_job_id, 
external_trigger, run_type, conf, data_interval_start, data_interval_end, 
last_scheduling_decision, dag_hash, log_template_id, updated_at, clear_number) 
VALUES (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, (SELECT 
max(log_template.id) AS max_1
   2024-02-23T20:01:52.729Z | FROM log_template), %s, %s)]


-- 
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]

Reply via email to