Skip to content

Schedule Batch Events registry rows from Airflow#429

Draft
krowvin wants to merge 24 commits into
USACE:cwbi-devfrom
krowvin:batch-dynamic-runtime/airflow-scheduled-events
Draft

Schedule Batch Events registry rows from Airflow#429
krowvin wants to merge 24 commits into
USACE:cwbi-devfrom
krowvin:batch-dynamic-runtime/airflow-scheduled-events

Conversation

@krowvin

@krowvin krowvin commented Jun 27, 2026

Copy link
Copy Markdown

Parent: USACE/cwms-data-api#1772

Summary

  • Adds registry-driven Airflow scheduling through Batch Events instead of direct AWS Batch submission.
  • Supports default or per-office scheduler Keycloak clients and optional configured scheduled office lists.
  • Evaluates hourly and cron schedules in each script's scheduleTimezone; DST gaps are skipped and repeated occurrences run once.

Validation

  • python -m pytest tests\dags\unit\test_batch_events_helper.py -q
  • Docker Airflow DAG harness was run during the broader end-to-end verification.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant