Task Instances

Reset Filters
  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-flow-job_v002 check_cluster_status 2023-02-20T13:00:00+00:00 EmrJobFlowSensor 2023-02-20T14:01:00.607532+00:00 2023-02-20T14:11:02.592150+00:00 0:10:01.984618 343288 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-20T14:00:58.206098+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-20T13:00:00+00:00 EmrCreateJobFlowOperator 2023-02-20T14:00:40.663522+00:00 2023-02-20T14:00:41.534936+00:00 0:00:00.871414 343286 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-20T14:00:38.223420+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-20T13:00:00+00:00 PythonOperator 2023-02-20T14:00:18.522059+00:00 2023-02-20T14:00:22.298156+00:00 0:00:03.776097 343284 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-20T14:00:16.205548+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-20T12:00:00+00:00 TriggerDagRunOperator 2023-02-20T13:11:03.089729+00:00 2023-02-20T13:11:03.619775+00:00 0:00:00.530046 343269 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-20T13:10:59.967908+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-20T12:00:00+00:00 TriggerDagRunOperator 2023-02-20T13:11:02.892241+00:00 2023-02-20T13:11:03.397255+00:00 0:00:00.505014 343268 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-20T13:10:59.967871+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-20T12:00:00+00:00 EmrJobFlowSensor 2023-02-20T13:00:46.992830+00:00 2023-02-20T13:10:48.781370+00:00 0:10:01.788540 343264 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-20T13:00:44.731326+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-20T12:00:00+00:00 EmrCreateJobFlowOperator 2023-02-20T13:00:26.896488+00:00 2023-02-20T13:00:27.754027+00:00 0:00:00.857539 343262 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-20T13:00:24.674540+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-20T12:00:00+00:00 PythonOperator 2023-02-20T13:00:05.370099+00:00 2023-02-20T13:00:09.245201+00:00 0:00:03.875102 343260 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-20T13:00:02.655368+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-20T11:00:00+00:00 TriggerDagRunOperator 2023-02-20T12:14:52.618267+00:00 2023-02-20T12:14:53.125628+00:00 0:00:00.507361 343250 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-20T12:14:49.648807+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-20T11:00:00+00:00 TriggerDagRunOperator 2023-02-20T12:14:52.296819+00:00 2023-02-20T12:14:52.772156+00:00 0:00:00.475337 343249 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-20T12:14:49.648835+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-20T11:00:00+00:00 EmrJobFlowSensor 2023-02-20T12:01:41.857012+00:00 2023-02-20T12:11:43.641168+00:00 0:10:01.784156 343243 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-20T12:01:38.876942+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-20T11:00:00+00:00 EmrCreateJobFlowOperator 2023-02-20T12:01:19.153613+00:00 2023-02-20T12:01:20.075846+00:00 0:00:00.922233 343240 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-20T12:01:16.853681+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-20T11:00:00+00:00 PythonOperator 2023-02-20T12:00:59.910695+00:00 2023-02-20T12:01:04.563137+00:00 0:00:04.652442 343239 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-20T12:00:56.837278+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-20T10:00:00+00:00 TriggerDagRunOperator 2023-02-20T11:10:09.486863+00:00 2023-02-20T11:10:10.064481+00:00 0:00:00.577618 343226 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-20T11:10:07.240540+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-20T10:00:00+00:00 TriggerDagRunOperator 2023-02-20T11:10:09.446445+00:00 2023-02-20T11:10:09.931287+00:00 0:00:00.484842 343225 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-20T11:10:07.240567+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-20T10:00:00+00:00 EmrJobFlowSensor 2023-02-20T11:00:58.471093+00:00 2023-02-20T11:10:00.201216+00:00 0:09:01.730123 343218 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-20T11:00:55.990209+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-20T10:00:00+00:00 EmrCreateJobFlowOperator 2023-02-20T11:00:38.161803+00:00 2023-02-20T11:00:38.993805+00:00 0:00:00.832002 343216 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-20T11:00:35.890875+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-20T10:00:00+00:00 PythonOperator 2023-02-20T11:00:16.364785+00:00 2023-02-20T11:00:20.212540+00:00 0:00:03.847755 343214 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-20T11:00:13.907343+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-20T09:00:00+00:00 TriggerDagRunOperator 2023-02-20T10:27:33.752077+00:00 2023-02-20T10:27:34.269209+00:00 0:00:00.517132 343205 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-20T10:27:30.876999+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-20T09:00:00+00:00 TriggerDagRunOperator 2023-02-20T10:27:33.446642+00:00 2023-02-20T10:27:33.905962+00:00 0:00:00.459320 343204 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-20T10:27:30.877028+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-20T09:00:00+00:00 EmrJobFlowSensor 2023-02-20T10:09:24.280825+00:00 2023-02-20T10:19:25.990450+00:00 0:10:01.709625 343201 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-20T10:09:22.035752+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-20T09:00:00+00:00 EmrCreateJobFlowOperator 2023-02-20T10:09:02.179792+00:00 2023-02-20T10:09:03.082333+00:00 0:00:00.902541 343198 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-20T10:08:59.976900+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-20T09:00:00+00:00 PythonOperator 2023-02-20T10:08:40.183037+00:00 2023-02-20T10:08:43.283366+00:00 0:00:03.100329 343195 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-20T10:08:37.966180+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-20T08:00:00+00:00 TriggerDagRunOperator 2023-02-20T09:21:39.996100+00:00 2023-02-20T09:21:40.513343+00:00 0:00:00.517243 343183 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-20T09:21:37.045101+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-20T08:00:00+00:00 TriggerDagRunOperator 2023-02-20T09:21:39.823144+00:00 2023-02-20T09:21:40.304573+00:00 0:00:00.481429 343182 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-20T09:21:37.045073+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-20T08:00:00+00:00 EmrJobFlowSensor 2023-02-20T09:09:38.827842+00:00 2023-02-20T09:20:40.719371+00:00 0:11:01.891529 343179 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-20T09:09:36.635832+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-20T08:00:00+00:00 EmrCreateJobFlowOperator 2023-02-20T09:09:18.802035+00:00 2023-02-20T09:09:19.620771+00:00 0:00:00.818736 343176 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-20T09:09:16.560144+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-20T08:00:00+00:00 PythonOperator 2023-02-20T09:08:57.159708+00:00 2023-02-20T09:09:00.518531+00:00 0:00:03.358823 343173 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-20T09:08:54.549843+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-20T07:00:00+00:00 TriggerDagRunOperator 2023-02-20T08:17:17.486002+00:00 2023-02-20T08:17:18.054908+00:00 0:00:00.568906 343160 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-20T08:17:14.805874+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-20T07:00:00+00:00 TriggerDagRunOperator 2023-02-20T08:17:17.318852+00:00 2023-02-20T08:17:17.801169+00:00 0:00:00.482317 343159 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-20T08:17:14.805845+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-20T07:00:00+00:00 EmrJobFlowSensor 2023-02-20T08:06:59.985398+00:00 2023-02-20T08:17:02.079961+00:00 0:10:02.094563 343154 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-20T08:06:57.832116+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-20T07:00:00+00:00 EmrCreateJobFlowOperator 2023-02-20T08:06:40.157321+00:00 2023-02-20T08:06:41.077269+00:00 0:00:00.919948 343151 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-20T08:06:37.772067+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-20T07:00:00+00:00 PythonOperator 2023-02-20T08:06:18.671076+00:00 2023-02-20T08:06:22.005482+00:00 0:00:03.334406 343148 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-20T08:06:15.731353+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-20T06:00:00+00:00 TriggerDagRunOperator 2023-02-20T07:17:49.436006+00:00 2023-02-20T07:17:49.900585+00:00 0:00:00.464579 343136 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-20T07:17:46.614473+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-20T06:00:00+00:00 TriggerDagRunOperator 2023-02-20T07:17:49.193553+00:00 2023-02-20T07:17:49.664704+00:00 0:00:00.471151 343135 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-20T07:17:46.614510+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-20T06:00:00+00:00 EmrJobFlowSensor 2023-02-20T07:04:09.737825+00:00 2023-02-20T07:14:11.529386+00:00 0:10:01.791561 343129 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-20T07:04:06.797000+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-20T06:00:00+00:00 EmrCreateJobFlowOperator 2023-02-20T07:03:47.248509+00:00 2023-02-20T07:03:48.152186+00:00 0:00:00.903677 343127 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-20T07:03:44.674033+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-20T06:00:00+00:00 PythonOperator 2023-02-20T07:03:27.996568+00:00 2023-02-20T07:03:33.016985+00:00 0:00:05.020417 343125 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-20T07:03:24.638563+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-20T05:00:00+00:00 TriggerDagRunOperator 2023-02-20T06:12:19.919836+00:00 2023-02-20T06:12:20.459820+00:00 0:00:00.539984 343112 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-20T06:12:17.516316+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-20T05:00:00+00:00 TriggerDagRunOperator 2023-02-20T06:12:19.848482+00:00 2023-02-20T06:12:20.359486+00:00 0:00:00.511004 343111 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-20T06:12:17.516283+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-20T05:00:00+00:00 EmrJobFlowSensor 2023-02-20T06:01:04.004553+00:00 2023-02-20T06:12:06.010026+00:00 0:11:02.005473 343105 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-20T06:01:01.195176+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-20T05:00:00+00:00 EmrCreateJobFlowOperator 2023-02-20T06:00:41.597548+00:00 2023-02-20T06:00:42.467788+00:00 0:00:00.870240 343103 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-20T06:00:39.106835+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-20T05:00:00+00:00 PythonOperator 2023-02-20T06:00:21.387024+00:00 2023-02-20T06:00:24.481860+00:00 0:00:03.094836 343101 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-20T06:00:19.037983+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-20T04:00:00+00:00 TriggerDagRunOperator 2023-02-20T05:13:52.602954+00:00 2023-02-20T05:13:53.153347+00:00 0:00:00.550393 343089 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-20T05:13:49.758271+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-20T04:00:00+00:00 TriggerDagRunOperator 2023-02-20T05:13:52.404390+00:00 2023-02-20T05:13:52.854619+00:00 0:00:00.450229 343088 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-20T05:13:49.758300+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-20T04:00:00+00:00 EmrJobFlowSensor 2023-02-20T05:01:34.117946+00:00 2023-02-20T05:12:36.079183+00:00 0:11:01.961237 343082 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-20T05:01:31.468292+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-20T04:00:00+00:00 EmrCreateJobFlowOperator 2023-02-20T05:01:11.819412+00:00 2023-02-20T05:01:12.777796+00:00 0:00:00.958384 343080 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-20T05:01:09.444920+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-20T04:00:00+00:00 PythonOperator 2023-02-20T05:00:52.327431+00:00 2023-02-20T05:00:55.471883+00:00 0:00:03.144452 343078 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-20T05:00:49.432480+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-20T03:00:00+00:00 TriggerDagRunOperator 2023-02-20T04:21:17.074116+00:00 2023-02-20T04:21:17.557315+00:00 0:00:00.483199 343065 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-20T04:21:14.516999+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-20T03:00:00+00:00 TriggerDagRunOperator 2023-02-20T04:21:16.925120+00:00 2023-02-20T04:21:17.426216+00:00 0:00:00.501096 343064 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-20T04:21:14.517027+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-20T03:00:00+00:00 EmrJobFlowSensor 2023-02-20T04:11:07.055846+00:00 2023-02-20T04:21:08.852648+00:00 0:10:01.796802 343059 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-20T04:11:04.706421+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-20T03:00:00+00:00 EmrCreateJobFlowOperator 2023-02-20T04:10:45.176440+00:00 2023-02-20T04:10:46.140604+00:00 0:00:00.964164 343056 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-20T04:10:42.684591+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-20T03:00:00+00:00 PythonOperator 2023-02-20T04:10:25.377914+00:00 2023-02-20T04:10:29.214147+00:00 0:00:03.836233 343053 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-20T04:10:22.627865+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-20T02:00:00+00:00 TriggerDagRunOperator 2023-02-20T03:17:32.090034+00:00 2023-02-20T03:17:32.618890+00:00 0:00:00.528856 343039 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-20T03:17:29.217912+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-20T02:00:00+00:00 TriggerDagRunOperator 2023-02-20T03:17:32.034793+00:00 2023-02-20T03:17:32.511111+00:00 0:00:00.476318 343038 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-20T03:17:29.217949+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-20T02:00:00+00:00 EmrJobFlowSensor 2023-02-20T03:00:47.704124+00:00 2023-02-20T03:11:49.654316+00:00 0:11:01.950192 343034 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-20T03:00:44.308529+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-20T02:00:00+00:00 EmrCreateJobFlowOperator 2023-02-20T03:00:26.860538+00:00 2023-02-20T03:00:27.726646+00:00 0:00:00.866108 343032 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-20T03:00:24.295464+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-20T02:00:00+00:00 PythonOperator 2023-02-20T03:00:04.762341+00:00 2023-02-20T03:00:08.785344+00:00 0:00:04.023003 343030 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-20T03:00:02.215998+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-20T01:00:00+00:00 TriggerDagRunOperator 2023-02-20T02:11:18.206765+00:00 2023-02-20T02:11:18.711608+00:00 0:00:00.504843 343019 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-20T02:11:15.117846+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-20T01:00:00+00:00 TriggerDagRunOperator 2023-02-20T02:11:17.987276+00:00 2023-02-20T02:11:18.460808+00:00 0:00:00.473532 343018 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-20T02:11:15.117880+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-20T01:00:00+00:00 EmrJobFlowSensor 2023-02-20T02:00:48.691714+00:00 2023-02-20T02:10:50.973987+00:00 0:10:02.282273 343010 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-20T02:00:45.129005+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-20T01:00:00+00:00 EmrCreateJobFlowOperator 2023-02-20T02:00:25.954803+00:00 2023-02-20T02:00:26.893251+00:00 0:00:00.938448 343008 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-20T02:00:23.045316+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-20T01:00:00+00:00 PythonOperator 2023-02-20T02:00:05.551459+00:00 2023-02-20T02:00:09.464555+00:00 0:00:03.913096 343006 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-20T02:00:03.028355+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-20T00:00:00+00:00 TriggerDagRunOperator 2023-02-20T01:11:56.185914+00:00 2023-02-20T01:11:56.691102+00:00 0:00:00.505188 342987 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-20T01:11:53.179068+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-20T00:00:00+00:00 TriggerDagRunOperator 2023-02-20T01:11:55.855727+00:00 2023-02-20T01:11:56.443470+00:00 0:00:00.587743 342986 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-20T01:11:53.179099+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-20T00:00:00+00:00 EmrJobFlowSensor 2023-02-20T01:01:04.523511+00:00 2023-02-20T01:11:06.397101+00:00 0:10:01.873590 342979 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-20T01:01:01.990543+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-20T00:00:00+00:00 EmrCreateJobFlowOperator 2023-02-20T01:00:42.185862+00:00 2023-02-20T01:00:43.313193+00:00 0:00:01.127331 342977 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-20T01:00:39.940728+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-20T00:00:00+00:00 PythonOperator 2023-02-20T01:00:20.198743+00:00 2023-02-20T01:00:24.136747+00:00 0:00:03.938004 342975 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-20T01:00:17.914693+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-19T23:00:00+00:00 TriggerDagRunOperator 2023-02-20T00:22:12.769550+00:00 2023-02-20T00:22:13.249455+00:00 0:00:00.479905 342964 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-20T00:22:10.244679+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-19T23:00:00+00:00 TriggerDagRunOperator 2023-02-20T00:22:12.627883+00:00 2023-02-20T00:22:13.099228+00:00 0:00:00.471345 342963 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-20T00:22:10.244720+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-19T23:00:00+00:00 EmrJobFlowSensor 2023-02-20T00:12:00.393279+00:00 2023-02-20T00:22:02.283599+00:00 0:10:01.890320 342960 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-20T00:11:57.906365+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-19T23:00:00+00:00 EmrCreateJobFlowOperator 2023-02-20T00:11:38.190724+00:00 2023-02-20T00:11:39.042832+00:00 0:00:00.852108 342956 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-20T00:11:35.884417+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-19T23:00:00+00:00 PythonOperator 2023-02-20T00:11:18.071139+00:00 2023-02-20T00:11:21.988460+00:00 0:00:03.917321 342953 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-20T00:11:15.867138+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-19T22:00:00+00:00 TriggerDagRunOperator 2023-02-19T23:12:35.550768+00:00 2023-02-19T23:12:36.086575+00:00 0:00:00.535807 342941 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-19T23:12:33.046291+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-19T22:00:00+00:00 TriggerDagRunOperator 2023-02-19T23:12:35.405859+00:00 2023-02-19T23:12:35.880231+00:00 0:00:00.474372 342940 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-19T23:12:33.046335+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-19T22:00:00+00:00 EmrJobFlowSensor 2023-02-19T23:02:24.841888+00:00 2023-02-19T23:12:26.639279+00:00 0:10:01.797391 342934 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-19T23:02:22.466661+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-19T22:00:00+00:00 EmrCreateJobFlowOperator 2023-02-19T23:02:04.646462+00:00 2023-02-19T23:02:05.721594+00:00 0:00:01.075132 342932 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-19T23:02:02.439804+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-19T22:00:00+00:00 PythonOperator 2023-02-19T23:00:23.497738+00:00 2023-02-19T23:00:31.957283+00:00 0:00:08.459545 342926 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-19T23:00:20.505204+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-19T21:00:00+00:00 TriggerDagRunOperator 2023-02-19T22:12:09.711247+00:00 2023-02-19T22:12:10.277829+00:00 0:00:00.566582 342912 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-19T22:12:07.247091+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-19T21:00:00+00:00 TriggerDagRunOperator 2023-02-19T22:12:09.561906+00:00 2023-02-19T22:12:10.051969+00:00 0:00:00.490063 342911 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-19T22:12:07.247061+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-19T21:00:00+00:00 EmrJobFlowSensor 2023-02-19T22:01:45.527625+00:00 2023-02-19T22:11:47.333240+00:00 0:10:01.805615 342905 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-19T22:01:42.914392+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-19T21:00:00+00:00 EmrCreateJobFlowOperator 2023-02-19T22:01:25.360831+00:00 2023-02-19T22:01:26.233399+00:00 0:00:00.872568 342903 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-19T22:01:22.863553+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-19T21:00:00+00:00 PythonOperator 2023-02-19T22:00:18.413961+00:00 2023-02-19T22:00:21.766537+00:00 0:00:03.352576 342900 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-19T22:00:15.891949+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-19T20:00:00+00:00 TriggerDagRunOperator 2023-02-19T21:11:05.628501+00:00 2023-02-19T21:11:06.153921+00:00 0:00:00.525420 342886 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-19T21:11:02.855693+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-19T20:00:00+00:00 TriggerDagRunOperator 2023-02-19T21:11:05.381071+00:00 2023-02-19T21:11:05.841400+00:00 0:00:00.460329 342885 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-19T21:11:02.855720+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-19T20:00:00+00:00 EmrJobFlowSensor 2023-02-19T21:00:53.055253+00:00 2023-02-19T21:10:54.790127+00:00 0:10:01.734874 342877 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-19T21:00:50.369510+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-19T20:00:00+00:00 EmrCreateJobFlowOperator 2023-02-19T21:00:26.762192+00:00 2023-02-19T21:00:27.618899+00:00 0:00:00.856707 342875 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-19T21:00:24.465680+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-19T20:00:00+00:00 PythonOperator 2023-02-19T21:00:04.745044+00:00 2023-02-19T21:00:08.705097+00:00 0:00:03.960053 342873 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-19T21:00:02.430195+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-19T19:00:00+00:00 TriggerDagRunOperator 2023-02-19T20:11:09.414449+00:00 2023-02-19T20:11:09.857324+00:00 0:00:00.442875 342861 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-19T20:11:06.741209+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-19T19:00:00+00:00 TriggerDagRunOperator 2023-02-19T20:11:09.108667+00:00 2023-02-19T20:11:09.580834+00:00 0:00:00.472167 342860 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-19T20:11:06.741180+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-19T19:00:00+00:00 EmrJobFlowSensor 2023-02-19T20:00:50.571318+00:00 2023-02-19T20:10:52.501966+00:00 0:10:01.930648 342852 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-19T20:00:48.236899+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-19T19:00:00+00:00 EmrCreateJobFlowOperator 2023-02-19T20:00:28.633348+00:00 2023-02-19T20:00:29.443417+00:00 0:00:00.810069 342850 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-19T20:00:26.234179+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-19T19:00:00+00:00 PythonOperator 2023-02-19T20:00:06.905053+00:00 2023-02-19T20:00:09.895594+00:00 0:00:02.990541 342848 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-19T20:00:04.124795+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-19T18:00:00+00:00 TriggerDagRunOperator 2023-02-19T19:11:22.018394+00:00 2023-02-19T19:11:22.504563+00:00 0:00:00.486169 342835 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-19T19:11:19.245645+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-19T18:00:00+00:00 TriggerDagRunOperator 2023-02-19T19:11:21.726970+00:00 2023-02-19T19:11:22.207374+00:00 0:00:00.480404 342834 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-19T19:11:19.245683+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-19T18:00:00+00:00 EmrJobFlowSensor 2023-02-19T19:00:59.484910+00:00 2023-02-19T19:11:01.380544+00:00 0:10:01.895634 342827 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-19T19:00:57.192203+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-19T18:00:00+00:00 EmrCreateJobFlowOperator 2023-02-19T19:00:39.419505+00:00 2023-02-19T19:00:40.216449+00:00 0:00:00.796944 342825 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-19T19:00:37.173526+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-19T18:00:00+00:00 PythonOperator 2023-02-19T19:00:17.369139+00:00 2023-02-19T19:00:20.286096+00:00 0:00:02.916957 342823 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-19T19:00:15.154787+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-19T17:00:00+00:00 TriggerDagRunOperator 2023-02-19T18:11:07.079344+00:00 2023-02-19T18:11:07.564564+00:00 0:00:00.485220 342809 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-19T18:11:03.959896+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-19T17:00:00+00:00 TriggerDagRunOperator 2023-02-19T18:11:07.016892+00:00 2023-02-19T18:11:07.555810+00:00 0:00:00.538918 342808 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-19T18:11:03.959931+00:00 2 default_pool