seanmuth commented on issue #68248:
URL: https://github.com/apache/airflow/issues/68248#issuecomment-4652612513
```
Astro Runtime Version: 3.1-15
Successfully connected to host:
interstellar-impact-6799-redis.interstellar-impact-6799.svc.cluster.local. 6379
Waiting for host:
interstellar-impact-6799-redis.interstellar-impact-6799.svc.cluster.local. 6379
Successfully connected to host:
interstellar-impact-6799-pgbouncer.interstellar-impact-6799.svc.cluster.local
6543
Waiting for host:
interstellar-impact-6799-pgbouncer.interstellar-impact-6799.svc.cluster.local
6543
Executing original entrypoint with parameters: airflow scheduler
Python path:
/usr/local/airflow:/usr/local/airflow/dags/dataplatformairflow/:/usr/local/airflow/dags/dataplatformairflow/dataplatformairflowairflow/:/usr/local/airflow/dags/featurebuilder/:/usr/local/airflow/dags/featurebuilder/featurebuilderairflow/:/usr/local/airflow/dags/etl/lib:/usr/local/airflow/plugins/src/
Skipping sync_runtime.py on current pod.
INFO __main__ Successfully loaded 949 confidant credentials into
/etc/profile.d/airflow_env.sh
INFO __main__ Decrypting data key with KMS key
alias/dataplatformastro-confidant-etl-production-iad
INFO __main__ Reading metadata from
s3://production-astronomer-data/confidant_credentials/featurebuilder-production.bin
INFO __main__ Fetching confidant bundle from
s3://production-astronomer-data/confidant_credentials/featurebuilder-production.bin
For further information visit
https://errors.pydantic.dev/2.13/v/uuid_type
UUID input should be a string, bytes or UUID object [type=uuid_type,
input_value=None, input_type=NoneType]
last_ti.dag_version_id
pydantic_core._pydantic_core.ValidationError: 1 validation error for
DagRunContext
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
validated_self = self.__pydantic_validator__.validate_python(data,
self_instance=self)
File "/usr/local/lib/python3.11/site-packages/pydantic/main.py", line 263,
in __init__
^^^^^^^^^^^^^^
context_from_server=DagRunContext(
File
"/usr/local/lib/python3.11/site-packages/airflow/jobs/scheduler_job_runner.py",
line 2047, in _schedule_dag_run
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
callback_tuples = [(run, self._schedule_dag_run(run, session=session))
for run in dag_runs]
File
"/usr/local/lib/python3.11/site-packages/airflow/jobs/scheduler_job_runner.py",
line 1972, in <listcomp>
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
callback_tuples = [(run, self._schedule_dag_run(run, session=session))
for run in dag_runs]
File
"/usr/local/lib/python3.11/site-packages/airflow/jobs/scheduler_job_runner.py",
line 1972, in _schedule_all_dag_runs
^^^^^^^^^^^^^^^^^^^^^
return func(*args, **kwargs)
File "/usr/local/lib/python3.11/site-packages/airflow/utils/retries.py",
line 106, in wrapped_function
raise self._exception
File "/usr/local/lib/python3.11/concurrent/futures/_base.py", line 401, in
__get_result
^^^^^^^^^^^^^^^^^^^
return self.__get_result()
File "/usr/local/lib/python3.11/concurrent/futures/_base.py", line 449, in
result
^^^^^^^^^^^^^^^^^^^
self._add_action_func(lambda rs: rs.outcome.result())
File "/usr/local/lib/python3.11/site-packages/tenacity/__init__.py", line
393, in <lambda>
^^^^^^^^^^^^^^^^^^^
result = action(retry_state)
File "/usr/local/lib/python3.11/site-packages/tenacity/__init__.py", line
371, in iter
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
do = self.iter(retry_state=retry_state)
File "/usr/local/lib/python3.11/site-packages/tenacity/__init__.py", line
438, in __iter__
for attempt in run_with_db_retries(max_retries=retries, logger=logger,
**retry_kwargs):
File "/usr/local/lib/python3.11/site-packages/airflow/utils/retries.py",
line 97, in wrapped_function
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
callback_tuples = self._schedule_all_dag_runs(guard, dag_runs, session)
File
"/usr/local/lib/python3.11/site-packages/airflow/jobs/scheduler_job_runner.py",
line 1530, in _do_scheduling
^^^^^^^^^^^^^^^^^^^^^^^^^^^^
num_queued_tis = self._do_scheduling(session)
File
"/usr/local/lib/python3.11/site-packages/airflow/jobs/scheduler_job_runner.py",
line 1420, in _run_scheduler_loop
self._run_scheduler_loop()
File
"/usr/local/lib/python3.11/site-packages/airflow/jobs/scheduler_job_runner.py",
line 1130, in _execute
^^^^^^^^^^^^^^^^^^
ret = execute_callable()
File "/usr/local/lib/python3.11/site-packages/airflow/jobs/job.py", line
397, in execute_job
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
return execute_job(job, execute_callable=execute_callable)
File "/usr/local/lib/python3.11/site-packages/airflow/jobs/job.py", line
368, in run_job
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
return func(*args, session=session, **kwargs)
File "/usr/local/lib/python3.11/site-packages/airflow/utils/session.py",
line 100, in wrapper
run_job(job=job_runner.job, execute_callable=job_runner._execute)
File
"/usr/local/lib/python3.11/site-packages/airflow/cli/commands/scheduler_command.py",
line 43, in _run_scheduler_job
^^^^^^^^^^^^^^^^^^^^^^^^
callback=lambda: _run_scheduler_job(args),
File
"/usr/local/lib/python3.11/site-packages/airflow/cli/commands/scheduler_command.py",
line 55, in <lambda>
callback()
File
"/usr/local/lib/python3.11/site-packages/airflow/cli/commands/daemon_utils.py",
line 86, in run_command_with_daemon_option
run_command_with_daemon_option(
File
"/usr/local/lib/python3.11/site-packages/airflow/cli/commands/scheduler_command.py",
line 52, in scheduler
^^^^^^^^^^^^^^^^^^^^^
return func(*args, **kwargs)
File
"/usr/local/lib/python3.11/site-packages/airflow/utils/providers_configuration_loader.py",
line 54, in wrapped_function
^^^^^^^^^^^^^^^^^^
return f(*args, **kwargs)
File "/usr/local/lib/python3.11/site-packages/airflow/utils/cli.py", line
114, in wrapper
^^^^^^^^^^^^^^^^^^^^^
return func(*args, **kwargs)
File "/usr/local/lib/python3.11/site-packages/airflow/cli/cli_config.py",
line 49, in command
args.func(args)
File "/usr/local/lib/python3.11/site-packages/airflow/__main__.py", line
55, in main
^^^^^^
sys.exit(main())
File "/usr/local/bin/airflow", line 10, in <module>
2026-06-08T18:01:07.851703Z [info ] Exited execute loop
[airflow.jobs.scheduler_job_runner.SchedulerJobRunner]
loc=scheduler_job_runner.py:1146
For further information visit
https://errors.pydantic.dev/2.13/v/uuid_type
UUID input should be a string, bytes or UUID object [type=uuid_type,
input_value=None, input_type=NoneType]
last_ti.dag_version_id
pydantic_core._pydantic_core.ValidationError: 1 validation error for
DagRunContext
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
validated_self = self.__pydantic_validator__.validate_python(data,
self_instance=self)
File "/usr/local/lib/python3.11/site-packages/pydantic/main.py", line 263,
in __init__
^^^^^^^^^^^^^^
context_from_server=DagRunContext(
File
"/usr/local/lib/python3.11/site-packages/airflow/jobs/scheduler_job_runner.py",
line 2047, in _schedule_dag_run
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
callback_tuples = [(run, self._schedule_dag_run(run, session=session))
for run in dag_runs]
File
"/usr/local/lib/python3.11/site-packages/airflow/jobs/scheduler_job_runner.py",
line 1972, in <listcomp>
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
callback_tuples = [(run, self._schedule_dag_run(run, session=session))
for run in dag_runs]
File
"/usr/local/lib/python3.11/site-packages/airflow/jobs/scheduler_job_runner.py",
line 1972, in _schedule_all_dag_runs
^^^^^^^^^^^^^^^^^^^^^
return func(*args, **kwargs)
File "/usr/local/lib/python3.11/site-packages/airflow/utils/retries.py",
line 106, in wrapped_function
raise self._exception
File "/usr/local/lib/python3.11/concurrent/futures/_base.py", line 401, in
__get_result
^^^^^^^^^^^^^^^^^^^
return self.__get_result()
File "/usr/local/lib/python3.11/concurrent/futures/_base.py", line 449, in
result
^^^^^^^^^^^^^^^^^^^
self._add_action_func(lambda rs: rs.outcome.result())
File "/usr/local/lib/python3.11/site-packages/tenacity/__init__.py", line
393, in <lambda>
^^^^^^^^^^^^^^^^^^^
result = action(retry_state)
File "/usr/local/lib/python3.11/site-packages/tenacity/__init__.py", line
371, in iter
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
do = self.iter(retry_state=retry_state)
File "/usr/local/lib/python3.11/site-packages/tenacity/__init__.py", line
438, in __iter__
for attempt in run_with_db_retries(max_retries=retries, logger=logger,
**retry_kwargs):
File "/usr/local/lib/python3.11/site-packages/airflow/utils/retries.py",
line 97, in wrapped_function
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
callback_tuples = self._schedule_all_dag_runs(guard, dag_runs, session)
File
"/usr/local/lib/python3.11/site-packages/airflow/jobs/scheduler_job_runner.py",
line 1530, in _do_scheduling
^^^^^^^^^^^^^^^^^^^^^^^^^^^^
num_queued_tis = self._do_scheduling(session)
File
"/usr/local/lib/python3.11/site-packages/airflow/jobs/scheduler_job_runner.py",
line 1420, in _run_scheduler_loop
self._run_scheduler_loop()
File
"/usr/local/lib/python3.11/site-packages/airflow/jobs/scheduler_job_runner.py",
line 1130, in _execute
```
--
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]
