File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change 2323from airflow .models .param import Param
2424from airflow .operators .trigger_dagrun import TriggerDagRunOperator
2525from airflow .utils .trigger_rule import TriggerRule
26- from xlml .utils .github import fire_github_callback , validate_git_trigger
26+ from xlml .utils .github import trigger_github_repository_dispatch , validate_git_trigger
2727
2828with models .DAG (
2929 dag_id = "maxtext_e2e_tests" ,
7979 poke_interval = 600 , # check every 10 minutes for child DAG completion
8080 )
8181
82- github_callback_pre_training = fire_github_callback .override (
82+ github_callback_pre_training = trigger_github_repository_dispatch .override (
8383 task_id = "fire_github_callback_pre_training" ,
8484 trigger_rule = TriggerRule .ALL_SUCCESS ,
8585 )(test_type = "pre_training" )
8686
87- github_callback_post_training = fire_github_callback .override (
87+ github_callback_post_training = trigger_github_repository_dispatch .override (
8888 task_id = "fire_github_callback_post_training" ,
8989 trigger_rule = TriggerRule .ALL_SUCCESS ,
9090 )(test_type = "post_training" )
Original file line number Diff line number Diff line change @@ -44,7 +44,7 @@ def validate_git_trigger() -> None:
4444
4545
4646@task
47- def fire_github_callback (
47+ def trigger_github_repository_dispatch (
4848 test_type : str | None = None ,
4949 repo : str | None = None ,
5050 token : str | None = None ,
@@ -99,4 +99,4 @@ def fire_github_callback(
9999 response .raise_for_status ()
100100
101101
102- trigger_github_repository_dispatch = fire_github_callback
102+ fire_github_callback = trigger_github_repository_dispatch
You can’t perform that action at this time.
0 commit comments