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-18T01:00:00+00:00 EmrJobFlowSensor 2023-02-18T02:01:04.827583+00:00 2023-02-18T02:11:06.601084+00:00 0:10:01.773501 341783 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-18T02:01:02.594842+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-18T01:00:00+00:00 EmrCreateJobFlowOperator 2023-02-18T02:00:44.896138+00:00 2023-02-18T02:00:45.963169+00:00 0:00:01.067031 341781 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-18T02:00:42.564060+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-18T01:00:00+00:00 PythonOperator 2023-02-18T02:00:23.132900+00:00 2023-02-18T02:00:26.392521+00:00 0:00:03.259621 341779 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-18T02:00:20.545111+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-18T00:00:00+00:00 TriggerDagRunOperator 2023-02-18T01:11:05.232396+00:00 2023-02-18T01:11:05.702168+00:00 0:00:00.469772 341758 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-18T01:11:02.738185+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-18T00:00:00+00:00 TriggerDagRunOperator 2023-02-18T01:11:05.083471+00:00 2023-02-18T01:11:05.585670+00:00 0:00:00.502199 341757 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-18T01:11:02.738215+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-18T00:00:00+00:00 EmrJobFlowSensor 2023-02-18T01:00:52.034490+00:00 2023-02-18T01:10:53.846037+00:00 0:10:01.811547 341750 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-18T01:00:48.304272+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-18T00:00:00+00:00 EmrCreateJobFlowOperator 2023-02-18T01:00:28.536673+00:00 2023-02-18T01:00:29.378101+00:00 0:00:00.841428 341748 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-18T01:00:26.280896+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-18T00:00:00+00:00 PythonOperator 2023-02-18T01:00:07.050950+00:00 2023-02-18T01:00:11.119093+00:00 0:00:04.068143 341746 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-18T01:00:04.315030+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-17T23:00:00+00:00 TriggerDagRunOperator 2023-02-18T00:11:01.627326+00:00 2023-02-18T00:11:02.166315+00:00 0:00:00.538989 341731 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-18T00:10:59.115712+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-17T23:00:00+00:00 TriggerDagRunOperator 2023-02-18T00:11:01.444881+00:00 2023-02-18T00:11:01.953210+00:00 0:00:00.508329 341730 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-18T00:10:59.115741+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-17T23:00:00+00:00 EmrJobFlowSensor 2023-02-18T00:00:55.171090+00:00 2023-02-18T00:10:57.006717+00:00 0:10:01.835627 341723 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-18T00:00:52.627808+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-17T23:00:00+00:00 EmrCreateJobFlowOperator 2023-02-18T00:00:32.775120+00:00 2023-02-18T00:00:33.575749+00:00 0:00:00.800629 341721 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-18T00:00:30.586347+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-17T23:00:00+00:00 PythonOperator 2023-02-18T00:00:13.143967+00:00 2023-02-18T00:00:17.007199+00:00 0:00:03.863232 341719 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-18T00:00:10.569460+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-17T22:00:00+00:00 TriggerDagRunOperator 2023-02-17T23:11:15.209880+00:00 2023-02-17T23:11:15.703564+00:00 0:00:00.493684 341705 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-17T23:11:12.692964+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-17T22:00:00+00:00 TriggerDagRunOperator 2023-02-17T23:11:15.204560+00:00 2023-02-17T23:11:15.753731+00:00 0:00:00.549171 341704 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-17T23:11:12.692998+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-17T22:00:00+00:00 EmrJobFlowSensor 2023-02-17T23:00:56.736986+00:00 2023-02-17T23:10:58.656858+00:00 0:10:01.919872 341697 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-17T23:00:54.188857+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-17T22:00:00+00:00 EmrCreateJobFlowOperator 2023-02-17T23:00:36.093192+00:00 2023-02-17T23:00:37.272715+00:00 0:00:01.179523 341694 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-17T23:00:32.046492+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-17T22:00:00+00:00 PythonOperator 2023-02-17T23:00:14.345406+00:00 2023-02-17T23:00:18.066230+00:00 0:00:03.720824 341691 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-17T23:00:12.035037+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-17T21:00:00+00:00 TriggerDagRunOperator 2023-02-17T22:11:06.174158+00:00 2023-02-17T22:11:06.659130+00:00 0:00:00.484972 341677 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-17T22:11:02.915585+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-17T21:00:00+00:00 TriggerDagRunOperator 2023-02-17T22:11:06.040991+00:00 2023-02-17T22:11:06.589923+00:00 0:00:00.548932 341676 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-17T22:11:02.915627+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-17T21:00:00+00:00 EmrJobFlowSensor 2023-02-17T22:00:55.707403+00:00 2023-02-17T22:10:57.557300+00:00 0:10:01.849897 341669 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-17T22:00:53.528960+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-17T21:00:00+00:00 EmrCreateJobFlowOperator 2023-02-17T22:00:33.640689+00:00 2023-02-17T22:00:34.451754+00:00 0:00:00.811065 341667 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-17T22:00:31.437250+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-17T21:00:00+00:00 PythonOperator 2023-02-17T22:00:11.714610+00:00 2023-02-17T22:00:14.751502+00:00 0:00:03.036892 341665 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-17T22:00:09.408745+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-17T20:00:00+00:00 TriggerDagRunOperator 2023-02-17T21:10:56.136158+00:00 2023-02-17T21:10:56.767109+00:00 0:00:00.630951 341651 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-17T21:10:53.487149+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-17T20:00:00+00:00 TriggerDagRunOperator 2023-02-17T21:10:55.932752+00:00 2023-02-17T21:10:56.613665+00:00 0:00:00.680913 341650 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-17T21:10:53.487116+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-17T20:00:00+00:00 EmrJobFlowSensor 2023-02-17T21:00:48.817922+00:00 2023-02-17T21:10:50.485957+00:00 0:10:01.668035 341643 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-17T21:00:46.393958+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-17T20:00:00+00:00 EmrCreateJobFlowOperator 2023-02-17T21:00:27.164489+00:00 2023-02-17T21:00:28.041378+00:00 0:00:00.876889 341642 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-17T21:00:24.311516+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-17T20:00:00+00:00 PythonOperator 2023-02-17T21:00:06.939764+00:00 2023-02-17T21:00:10.885182+00:00 0:00:03.945418 341640 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-17T21:00:04.314531+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-17T19:00:00+00:00 TriggerDagRunOperator 2023-02-17T20:11:20.668601+00:00 2023-02-17T20:11:21.238066+00:00 0:00:00.569465 341624 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-17T20:11:18.173608+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-17T19:00:00+00:00 TriggerDagRunOperator 2023-02-17T20:11:20.635167+00:00 2023-02-17T20:11:21.171060+00:00 0:00:00.535893 341623 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-17T20:11:18.173636+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-17T19:00:00+00:00 EmrJobFlowSensor 2023-02-17T20:01:06.293458+00:00 2023-02-17T20:11:08.154242+00:00 0:10:01.860784 341617 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-17T20:01:03.856435+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-17T19:00:00+00:00 EmrCreateJobFlowOperator 2023-02-17T20:00:44.930396+00:00 2023-02-17T20:00:46.016317+00:00 0:00:01.085921 341615 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-17T20:00:41.830571+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-17T19:00:00+00:00 PythonOperator 2023-02-17T20:00:24.647966+00:00 2023-02-17T20:00:28.252687+00:00 0:00:03.604721 341613 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-17T20:00:21.903008+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-17T18:00:00+00:00 TriggerDagRunOperator 2023-02-17T19:11:26.198593+00:00 2023-02-17T19:11:26.784740+00:00 0:00:00.586147 341597 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-17T19:11:23.392472+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-17T18:00:00+00:00 TriggerDagRunOperator 2023-02-17T19:11:25.945440+00:00 2023-02-17T19:11:26.654017+00:00 0:00:00.708577 341596 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-17T19:11:23.392442+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-17T18:00:00+00:00 EmrJobFlowSensor 2023-02-17T19:01:05.139686+00:00 2023-02-17T19:11:06.916744+00:00 0:10:01.777058 341590 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-17T19:01:02.690739+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-17T18:00:00+00:00 EmrCreateJobFlowOperator 2023-02-17T19:00:47.557804+00:00 2023-02-17T19:00:48.421934+00:00 0:00:00.864130 341588 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-17T19:00:42.602252+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-17T18:00:00+00:00 PythonOperator 2023-02-17T19:00:22.788408+00:00 2023-02-17T19:00:26.711183+00:00 0:00:03.922775 341586 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-17T19:00:20.497915+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-17T17:00:00+00:00 TriggerDagRunOperator 2023-02-17T18:11:13.222563+00:00 2023-02-17T18:11:13.703181+00:00 0:00:00.480618 341571 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-17T18:11:10.198084+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-17T17:00:00+00:00 TriggerDagRunOperator 2023-02-17T18:11:13.191957+00:00 2023-02-17T18:11:13.760733+00:00 0:00:00.568776 341570 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-17T18:11:10.198112+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-17T17:00:00+00:00 EmrJobFlowSensor 2023-02-17T18:01:01.652946+00:00 2023-02-17T18:11:03.583178+00:00 0:10:01.930232 341564 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-17T18:00:59.312548+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-17T17:00:00+00:00 EmrCreateJobFlowOperator 2023-02-17T18:00:39.625446+00:00 2023-02-17T18:00:40.463995+00:00 0:00:00.838549 341562 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-17T18:00:37.302528+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-17T17:00:00+00:00 PythonOperator 2023-02-17T18:00:19.384026+00:00 2023-02-17T18:00:23.238757+00:00 0:00:03.854731 341560 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-17T18:00:17.163476+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-17T16:00:00+00:00 TriggerDagRunOperator 2023-02-17T17:11:13.024880+00:00 2023-02-17T17:11:13.544860+00:00 0:00:00.519980 341546 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-17T17:11:10.296593+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-17T16:00:00+00:00 TriggerDagRunOperator 2023-02-17T17:11:12.697802+00:00 2023-02-17T17:11:13.175208+00:00 0:00:00.477406 341545 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-17T17:11:10.296550+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-17T16:00:00+00:00 EmrJobFlowSensor 2023-02-17T17:01:03.187234+00:00 2023-02-17T17:11:05.046508+00:00 0:10:01.859274 341539 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-17T17:01:01.003602+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-17T16:00:00+00:00 EmrCreateJobFlowOperator 2023-02-17T17:00:43.172976+00:00 2023-02-17T17:00:44.143429+00:00 0:00:00.970453 341537 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-17T17:00:40.947853+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-17T16:00:00+00:00 PythonOperator 2023-02-17T17:00:21.193824+00:00 2023-02-17T17:00:25.149241+00:00 0:00:03.955417 341535 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-17T17:00:18.918600+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-17T15:00:00+00:00 TriggerDagRunOperator 2023-02-17T16:11:31.709161+00:00 2023-02-17T16:11:32.210021+00:00 0:00:00.500860 341520 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-17T16:11:29.126743+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-17T15:00:00+00:00 TriggerDagRunOperator 2023-02-17T16:11:31.640843+00:00 2023-02-17T16:11:32.114839+00:00 0:00:00.473996 341519 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-17T16:11:29.126771+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-17T15:00:00+00:00 EmrJobFlowSensor 2023-02-17T16:01:05.779773+00:00 2023-02-17T16:11:07.627474+00:00 0:10:01.847701 341513 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-17T16:01:03.426977+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-17T15:00:00+00:00 EmrCreateJobFlowOperator 2023-02-17T16:00:44.092029+00:00 2023-02-17T16:00:45.547447+00:00 0:00:01.455418 341511 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-17T16:00:41.334743+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-17T15:00:00+00:00 PythonOperator 2023-02-17T16:00:23.673254+00:00 2023-02-17T16:00:26.497635+00:00 0:00:02.824381 341509 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-17T16:00:21.321015+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-17T14:00:00+00:00 TriggerDagRunOperator 2023-02-17T15:30:53.299080+00:00 2023-02-17T15:30:53.841223+00:00 0:00:00.542143 341497 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-17T15:30:50.068325+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-17T14:00:00+00:00 TriggerDagRunOperator 2023-02-17T15:30:53.145079+00:00 2023-02-17T15:30:53.602846+00:00 0:00:00.457767 341496 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-17T15:30:50.068290+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-17T14:00:00+00:00 EmrJobFlowSensor 2023-02-17T15:00:50.853248+00:00 2023-02-17T15:10:52.831728+00:00 0:10:01.978480 341488 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-17T15:00:45.999524+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-17T14:00:00+00:00 EmrCreateJobFlowOperator 2023-02-17T15:00:26.216279+00:00 2023-02-17T15:00:27.071601+00:00 0:00:00.855322 341486 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-17T15:00:23.875438+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-17T14:00:00+00:00 PythonOperator 2023-02-17T15:00:06.472012+00:00 2023-02-17T15:00:09.353871+00:00 0:00:02.881859 341484 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-17T15:00:03.857749+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-17T13:00:00+00:00 TriggerDagRunOperator 2023-02-17T14:14:52.511010+00:00 2023-02-17T14:14:53.029711+00:00 0:00:00.518701 341472 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-17T14:14:49.259290+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-17T13:00:00+00:00 TriggerDagRunOperator 2023-02-17T14:14:52.117409+00:00 2023-02-17T14:14:52.601646+00:00 0:00:00.484237 341471 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-17T14:14:49.259327+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-17T13:00:00+00:00 EmrJobFlowSensor 2023-02-17T14:02:34.487258+00:00 2023-02-17T14:12:36.274146+00:00 0:10:01.786888 341465 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-17T14:02:32.031489+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-17T13:00:00+00:00 EmrCreateJobFlowOperator 2023-02-17T14:02:15.901987+00:00 2023-02-17T14:02:17.209502+00:00 0:00:01.307515 341463 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-17T14:02:12.011846+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-17T13:00:00+00:00 PythonOperator 2023-02-17T14:01:53.020698+00:00 2023-02-17T14:01:56.865584+00:00 0:00:03.844886 341461 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-17T14:01:49.941385+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-17T12:00:00+00:00 TriggerDagRunOperator 2023-02-17T13:11:59.130610+00:00 2023-02-17T13:11:59.682238+00:00 0:00:00.551628 341450 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-17T13:11:55.978302+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-17T12:00:00+00:00 TriggerDagRunOperator 2023-02-17T13:11:59.057410+00:00 2023-02-17T13:11:59.615033+00:00 0:00:00.557623 341449 airflow-worker-2.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-17T13:11:55.978333+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-17T12:00:00+00:00 EmrJobFlowSensor 2023-02-17T13:01:51.148798+00:00 2023-02-17T13:11:53.019238+00:00 0:10:01.870440 341442 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-17T13:01:48.637435+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-17T12:00:00+00:00 EmrCreateJobFlowOperator 2023-02-17T13:01:31.512573+00:00 2023-02-17T13:01:32.399906+00:00 0:00:00.887333 341440 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-17T13:01:28.627534+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-17T12:00:00+00:00 PythonOperator 2023-02-17T13:01:09.639104+00:00 2023-02-17T13:01:13.645260+00:00 0:00:04.006156 341438 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-17T13:01:06.608457+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-17T11:00:00+00:00 TriggerDagRunOperator 2023-02-17T12:23:21.693620+00:00 2023-02-17T12:23:22.215206+00:00 0:00:00.521586 341427 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-17T12:23:19.231924+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-17T11:00:00+00:00 TriggerDagRunOperator 2023-02-17T12:23:21.658266+00:00 2023-02-17T12:23:22.136663+00:00 0:00:00.478397 341426 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-17T12:23:19.231952+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-17T11:00:00+00:00 EmrJobFlowSensor 2023-02-17T12:13:04.194410+00:00 2023-02-17T12:23:06.037719+00:00 0:10:01.843309 341422 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-17T12:13:01.959896+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-17T11:00:00+00:00 EmrCreateJobFlowOperator 2023-02-17T12:12:44.806418+00:00 2023-02-17T12:12:45.825654+00:00 0:00:01.019236 341419 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-17T12:12:41.938251+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-17T11:00:00+00:00 PythonOperator 2023-02-17T12:12:22.369213+00:00 2023-02-17T12:12:25.551818+00:00 0:00:03.182605 341416 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-17T12:12:19.923110+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-17T10:00:00+00:00 TriggerDagRunOperator 2023-02-17T11:11:08.740930+00:00 2023-02-17T11:11:09.232293+00:00 0:00:00.491363 341402 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-17T11:11:06.381702+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-17T10:00:00+00:00 TriggerDagRunOperator 2023-02-17T11:11:08.707959+00:00 2023-02-17T11:11:09.204243+00:00 0:00:00.496284 341401 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-17T11:11:06.381737+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-17T10:00:00+00:00 EmrJobFlowSensor 2023-02-17T11:00:53.084198+00:00 2023-02-17T11:10:54.931320+00:00 0:10:01.847122 341395 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-17T11:00:50.086520+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-17T10:00:00+00:00 EmrCreateJobFlowOperator 2023-02-17T11:00:28.843930+00:00 2023-02-17T11:00:29.669215+00:00 0:00:00.825285 341393 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-17T11:00:26.120676+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-17T10:00:00+00:00 PythonOperator 2023-02-17T11:00:09.241741+00:00 2023-02-17T11:00:14.078074+00:00 0:00:04.836333 341391 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-17T11:00:06.051537+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-17T09:00:00+00:00 TriggerDagRunOperator 2023-02-17T10:11:20.377342+00:00 2023-02-17T10:11:20.900788+00:00 0:00:00.523446 341377 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-17T10:11:17.996317+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-17T09:00:00+00:00 TriggerDagRunOperator 2023-02-17T10:11:20.356466+00:00 2023-02-17T10:11:20.850986+00:00 0:00:00.494520 341376 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-17T10:11:17.996288+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-17T09:00:00+00:00 EmrJobFlowSensor 2023-02-17T10:00:53.488802+00:00 2023-02-17T10:10:55.147551+00:00 0:10:01.658749 341368 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-17T10:00:51.146225+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-17T09:00:00+00:00 EmrCreateJobFlowOperator 2023-02-17T10:00:31.847957+00:00 2023-02-17T10:00:32.755043+00:00 0:00:00.907086 341366 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-17T10:00:29.190788+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-17T09:00:00+00:00 PythonOperator 2023-02-17T10:00:11.712950+00:00 2023-02-17T10:00:15.797828+00:00 0:00:04.084878 341364 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-17T10:00:09.108019+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-17T08:00:00+00:00 TriggerDagRunOperator 2023-02-17T09:11:03.108546+00:00 2023-02-17T09:11:03.606359+00:00 0:00:00.497813 341350 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-17T09:11:00.572555+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-17T08:00:00+00:00 TriggerDagRunOperator 2023-02-17T09:11:02.980522+00:00 2023-02-17T09:11:03.454445+00:00 0:00:00.473923 341349 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-17T09:11:00.572525+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-17T08:00:00+00:00 EmrJobFlowSensor 2023-02-17T09:00:55.329219+00:00 2023-02-17T09:10:57.135841+00:00 0:10:01.806622 341342 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-17T09:00:53.144041+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-17T08:00:00+00:00 EmrCreateJobFlowOperator 2023-02-17T09:00:33.746087+00:00 2023-02-17T09:00:34.869443+00:00 0:00:01.123356 341340 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-17T09:00:31.116424+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-17T08:00:00+00:00 PythonOperator 2023-02-17T09:00:13.364221+00:00 2023-02-17T09:00:17.191786+00:00 0:00:03.827565 341338 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-17T09:00:11.079405+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-17T07:00:00+00:00 TriggerDagRunOperator 2023-02-17T08:11:08.871368+00:00 2023-02-17T08:11:09.345711+00:00 0:00:00.474343 341325 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-17T08:11:06.383986+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-17T07:00:00+00:00 TriggerDagRunOperator 2023-02-17T08:11:08.740863+00:00 2023-02-17T08:11:09.196521+00:00 0:00:00.455658 341324 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-17T08:11:06.384018+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-17T07:00:00+00:00 EmrJobFlowSensor 2023-02-17T08:00:59.386076+00:00 2023-02-17T08:11:01.225926+00:00 0:10:01.839850 341317 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-17T08:00:57.040282+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-17T07:00:00+00:00 EmrCreateJobFlowOperator 2023-02-17T08:00:37.333872+00:00 2023-02-17T08:00:38.140790+00:00 0:00:00.806918 341315 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-17T08:00:34.979718+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-17T07:00:00+00:00 PythonOperator 2023-02-17T08:00:17.385056+00:00 2023-02-17T08:00:20.483038+00:00 0:00:03.097982 341313 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-17T08:00:14.944061+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-17T06:00:00+00:00 TriggerDagRunOperator 2023-02-17T07:11:05.451235+00:00 2023-02-17T07:11:05.978305+00:00 0:00:00.527070 341299 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-17T07:11:02.893915+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-17T06:00:00+00:00 TriggerDagRunOperator 2023-02-17T07:11:05.299088+00:00 2023-02-17T07:11:05.780931+00:00 0:00:00.481843 341298 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-17T07:11:02.893881+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-17T06:00:00+00:00 EmrJobFlowSensor 2023-02-17T07:00:48.425487+00:00 2023-02-17T07:10:50.495950+00:00 0:10:02.070463 341291 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-17T07:00:43.654197+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-17T06:00:00+00:00 EmrCreateJobFlowOperator 2023-02-17T07:00:25.838401+00:00 2023-02-17T07:00:26.742941+00:00 0:00:00.904540 341289 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-17T07:00:23.635499+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-17T06:00:00+00:00 PythonOperator 2023-02-17T07:00:04.156293+00:00 2023-02-17T07:00:07.161717+00:00 0:00:03.005424 341287 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-17T07:00:01.566821+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-17T05:00:00+00:00 TriggerDagRunOperator 2023-02-17T06:12:13.407650+00:00 2023-02-17T06:12:13.942109+00:00 0:00:00.534459 341275 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-17T06:12:10.520027+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-17T05:00:00+00:00 TriggerDagRunOperator 2023-02-17T06:12:13.322902+00:00 2023-02-17T06:12:13.781721+00:00 0:00:00.458819 341274 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-17T06:12:10.520068+00:00 2 default_pool