Skip to content

Fix callback state not updating from executor events due to UUID type mismatch#67542

Merged
o-nikolas merged 2 commits into
apache:mainfrom
wjddn279:fix-callback-fetch-query-uuid
May 26, 2026
Merged

Fix callback state not updating from executor events due to UUID type mismatch#67542
o-nikolas merged 2 commits into
apache:mainfrom
wjddn279:fix-callback-fetch-query-uuid

Conversation

@wjddn279
Copy link
Copy Markdown
Contributor

failing test: https://github.com/apache/airflow/actions/runs/26440894620/job/77843758833?pr=66141

When filtering a UUID-typed column on the existing Callback table with a plain string, the following error is raised. This error does not surface on PostgreSQL, but it does on SQLite and MySQL.

FAILED airflow-core/tests/unit/jobs/test_scheduler_job.py::TestSchedulerJob::test_process_executor_events_failed_event_captures_output[queued] - sqlalchemy.exc.StatementError: (builtins.AttributeError) 'str' object has no attribute 'hex'
[SQL: SELECT callback.id AS callback_id, callback.type AS callback_type, callback.fetch_method AS callback_fetch_method, callback.data AS callback_data, callback.bundle_name AS callback_bundle_name, callback.state AS callback_state, callback.output AS callback_output, callback.priority_weight AS callback_priority_weight, callback.created_at AS callback_created_at, callback.trigger_id AS callback_trigger_id 
FROM callback 
WHERE callback.id = %s]
[parameters: [{'pk_1': '019e63b5-0c8e-7749-b423-236d64f5a623'}]]

The fix wraps the lookup value in UUID(...) instead of passing the raw string.


Was generative AI tooling used to co-author this PR?
  • Yes (please specify the tool below)

  • Read the Pull Request Guidelines for more information. Note: commit author/co-author name and email in commits become permanently public when merged.
  • For fundamental code changes, an Airflow Improvement Proposal (AIP) is needed.
  • When adding dependency, check compliance with the ASF 3rd Party License Policy.
  • For significant user-facing changes create newsfragment: {pr_number}.significant.rst, in airflow-core/newsfragments. You can add this file in a follow-up commit after the PR is created so you know the PR number.

@wjddn279 wjddn279 requested review from XD-DENG and ashb as code owners May 26, 2026 10:16
@boring-cyborg boring-cyborg Bot added the area:Scheduler including HA (high availability) scheduler label May 26, 2026
@o-nikolas o-nikolas merged commit 66a1a64 into apache:main May 26, 2026
79 checks passed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

area:Scheduler including HA (high availability) scheduler

Projects

None yet

Development

Successfully merging this pull request may close these issues.

4 participants