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 create_cluster_and_add_emr_steps 2023-04-30T18:00:00+00:00 EmrCreateJobFlowOperator 2023-04-30T19:00:40.110685+00:00 2023-04-30T19:00:40.870163+00:00 0:00:00.759478 370698 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-30T19:00:37.813238+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-30T18:00:00+00:00 PythonOperator 2023-04-30T19:00:19.369706+00:00 2023-04-30T19:00:21.151866+00:00 0:00:01.782160 370696 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-30T19:00:15.781994+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-30T17:00:00+00:00 TriggerDagRunOperator 2023-04-30T18:22:23.440975+00:00 2023-04-30T18:22:23.831252+00:00 0:00:00.390277 370682 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-30T18:22:21.244839+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-30T17:00:00+00:00 TriggerDagRunOperator 2023-04-30T18:22:23.377132+00:00 2023-04-30T18:22:23.875973+00:00 0:00:00.498841 370681 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-30T18:22:21.244807+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-30T17:00:00+00:00 EmrJobFlowSensor 2023-04-30T18:11:58.991583+00:00 2023-04-30T18:22:00.943684+00:00 0:10:01.952101 370677 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-30T18:11:56.779298+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-30T17:00:00+00:00 EmrCreateJobFlowOperator 2023-04-30T18:11:36.936838+00:00 2023-04-30T18:11:37.705830+00:00 0:00:00.768992 370675 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-30T18:11:34.750062+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-30T17:00:00+00:00 PythonOperator 2023-04-30T18:11:17.126175+00:00 2023-04-30T18:11:18.056795+00:00 0:00:00.930620 370672 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-30T18:11:14.792118+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-30T16:00:00+00:00 TriggerDagRunOperator 2023-04-30T17:12:31.698935+00:00 2023-04-30T17:12:32.148284+00:00 0:00:00.449349 370659 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-30T17:12:29.035923+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-30T16:00:00+00:00 TriggerDagRunOperator 2023-04-30T17:12:31.629743+00:00 2023-04-30T17:12:31.970655+00:00 0:00:00.340912 370658 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-30T17:12:29.035952+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-30T16:00:00+00:00 EmrJobFlowSensor 2023-04-30T17:00:58.133699+00:00 2023-04-30T17:12:00.195128+00:00 0:11:02.061429 370648 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-30T17:00:55.852886+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-30T16:00:00+00:00 EmrCreateJobFlowOperator 2023-04-30T17:00:36.550182+00:00 2023-04-30T17:00:37.457482+00:00 0:00:00.907300 370647 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-30T17:00:33.830230+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-30T16:00:00+00:00 PythonOperator 2023-04-30T17:00:16.064313+00:00 2023-04-30T17:00:16.977432+00:00 0:00:00.913119 370646 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-30T17:00:13.813152+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-30T15:00:00+00:00 TriggerDagRunOperator 2023-04-30T16:15:49.604062+00:00 2023-04-30T16:15:50.078594+00:00 0:00:00.474532 370634 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-30T16:15:46.165241+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-30T15:00:00+00:00 TriggerDagRunOperator 2023-04-30T16:15:48.852344+00:00 2023-04-30T16:15:49.207192+00:00 0:00:00.354848 370633 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-30T16:15:46.165211+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-30T15:00:00+00:00 EmrJobFlowSensor 2023-04-30T16:03:13.057693+00:00 2023-04-30T16:13:14.895998+00:00 0:10:01.838305 370627 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-30T16:03:10.918666+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-30T15:00:00+00:00 EmrCreateJobFlowOperator 2023-04-30T16:02:52.123217+00:00 2023-04-30T16:02:52.876694+00:00 0:00:00.753477 370625 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-30T16:02:48.905257+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-30T15:00:00+00:00 PythonOperator 2023-04-30T16:02:31.814860+00:00 2023-04-30T16:02:32.783302+00:00 0:00:00.968442 370623 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-30T16:02:28.896127+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-30T14:00:00+00:00 TriggerDagRunOperator 2023-04-30T15:11:02.716567+00:00 2023-04-30T15:11:03.052129+00:00 0:00:00.335562 370609 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-30T15:11:00.382625+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-30T14:00:00+00:00 TriggerDagRunOperator 2023-04-30T15:11:02.722295+00:00 2023-04-30T15:11:03.161547+00:00 0:00:00.439252 370608 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-30T15:11:00.382657+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-30T14:00:00+00:00 EmrJobFlowSensor 2023-04-30T15:00:54.778250+00:00 2023-04-30T15:10:56.686496+00:00 0:10:01.908246 370602 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-30T15:00:52.488077+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-30T14:00:00+00:00 EmrCreateJobFlowOperator 2023-04-30T15:00:34.574312+00:00 2023-04-30T15:00:35.688884+00:00 0:00:01.114572 370600 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-30T15:00:32.350961+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-30T14:00:00+00:00 PythonOperator 2023-04-30T15:00:12.930199+00:00 2023-04-30T15:00:13.782574+00:00 0:00:00.852375 370598 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-30T15:00:10.332270+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-30T13:00:00+00:00 TriggerDagRunOperator 2023-04-30T14:10:56.134047+00:00 2023-04-30T14:10:56.604620+00:00 0:00:00.470573 370585 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-30T14:10:53.278069+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-30T13:00:00+00:00 TriggerDagRunOperator 2023-04-30T14:10:55.566005+00:00 2023-04-30T14:10:55.991400+00:00 0:00:00.425395 370584 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-30T14:10:53.278102+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-30T13:00:00+00:00 EmrJobFlowSensor 2023-04-30T14:00:47.019824+00:00 2023-04-30T14:10:48.789998+00:00 0:10:01.770174 370577 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-30T14:00:44.785788+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-30T13:00:00+00:00 EmrCreateJobFlowOperator 2023-04-30T14:00:27.040399+00:00 2023-04-30T14:00:27.808863+00:00 0:00:00.768464 370575 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-30T14:00:24.712364+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-30T13:00:00+00:00 PythonOperator 2023-04-30T14:00:05.207346+00:00 2023-04-30T14:00:06.118362+00:00 0:00:00.911016 370573 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-30T14:00:02.697070+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-30T12:00:00+00:00 TriggerDagRunOperator 2023-04-30T13:35:30.709987+00:00 2023-04-30T13:35:31.222385+00:00 0:00:00.512398 370564 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-30T13:35:27.597194+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-30T12:00:00+00:00 TriggerDagRunOperator 2023-04-30T13:35:30.674493+00:00 2023-04-30T13:35:31.012777+00:00 0:00:00.338284 370563 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-30T13:35:27.597147+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-30T12:00:00+00:00 EmrJobFlowSensor 2023-04-30T13:24:18.054017+00:00 2023-04-30T13:35:19.989792+00:00 0:11:01.935775 370560 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-30T13:24:15.810725+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-30T12:00:00+00:00 EmrCreateJobFlowOperator 2023-04-30T13:23:55.924694+00:00 2023-04-30T13:23:56.692742+00:00 0:00:00.768048 370557 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-30T13:23:53.735404+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-30T12:00:00+00:00 PythonOperator 2023-04-30T13:23:35.992603+00:00 2023-04-30T13:23:36.917556+00:00 0:00:00.924953 370554 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-30T13:23:33.715892+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-30T11:00:00+00:00 TriggerDagRunOperator 2023-04-30T12:21:25.010522+00:00 2023-04-30T12:21:25.441144+00:00 0:00:00.430622 370541 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-30T12:21:22.607780+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-30T11:00:00+00:00 TriggerDagRunOperator 2023-04-30T12:21:24.923083+00:00 2023-04-30T12:21:25.257519+00:00 0:00:00.334436 370540 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-30T12:21:22.607740+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-30T11:00:00+00:00 EmrJobFlowSensor 2023-04-30T12:10:59.681629+00:00 2023-04-30T12:21:01.599180+00:00 0:10:01.917551 370537 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-30T12:10:57.383041+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-30T11:00:00+00:00 EmrCreateJobFlowOperator 2023-04-30T12:10:39.499033+00:00 2023-04-30T12:10:40.238657+00:00 0:00:00.739624 370534 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-30T12:10:37.291500+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-30T11:00:00+00:00 PythonOperator 2023-04-30T12:10:17.418904+00:00 2023-04-30T12:10:18.272759+00:00 0:00:00.853855 370531 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-30T12:10:15.276632+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-30T10:00:00+00:00 TriggerDagRunOperator 2023-04-30T11:11:18.826179+00:00 2023-04-30T11:11:19.282673+00:00 0:00:00.456494 370517 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-30T11:11:16.478253+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-30T10:00:00+00:00 TriggerDagRunOperator 2023-04-30T11:11:18.702196+00:00 2023-04-30T11:11:19.078027+00:00 0:00:00.375831 370516 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-30T11:11:16.478217+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-30T10:00:00+00:00 EmrJobFlowSensor 2023-04-30T11:00:55.658145+00:00 2023-04-30T11:10:57.520279+00:00 0:10:01.862134 370507 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-30T11:00:53.319559+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-30T10:00:00+00:00 EmrCreateJobFlowOperator 2023-04-30T11:00:33.435172+00:00 2023-04-30T11:00:34.213679+00:00 0:00:00.778507 370506 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-30T11:00:31.290071+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-30T10:00:00+00:00 PythonOperator 2023-04-30T11:00:13.456757+00:00 2023-04-30T11:00:14.383083+00:00 0:00:00.926326 370505 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-30T11:00:11.249976+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-30T09:00:00+00:00 TriggerDagRunOperator 2023-04-30T10:26:36.907928+00:00 2023-04-30T10:26:37.354721+00:00 0:00:00.446793 370491 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-30T10:26:34.692022+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-30T09:00:00+00:00 TriggerDagRunOperator 2023-04-30T10:26:36.801484+00:00 2023-04-30T10:26:37.144479+00:00 0:00:00.342995 370490 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-30T10:26:34.692050+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-30T09:00:00+00:00 EmrJobFlowSensor 2023-04-30T10:26:17.229790+00:00 2023-04-30T10:26:17.788402+00:00 0:00:00.558612 370487 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-30T10:26:14.677045+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-30T09:00:00+00:00 EmrCreateJobFlowOperator 2023-04-30T10:00:30.211900+00:00 2023-04-30T10:00:31.111122+00:00 0:00:00.899222 370485 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-30T10:00:27.463055+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-30T09:00:00+00:00 PythonOperator 2023-04-30T10:00:09.860946+00:00 2023-04-30T10:00:10.749130+00:00 0:00:00.888184 370483 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-30T10:00:07.438073+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-30T08:00:00+00:00 TriggerDagRunOperator 2023-04-30T09:25:57.631230+00:00 2023-04-30T09:25:58.089504+00:00 0:00:00.458274 370472 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-30T09:25:55.167140+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-30T08:00:00+00:00 TriggerDagRunOperator 2023-04-30T09:25:57.540163+00:00 2023-04-30T09:25:57.868456+00:00 0:00:00.328293 370471 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-30T09:25:55.167167+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-30T08:00:00+00:00 EmrJobFlowSensor 2023-04-30T09:01:04.233123+00:00 2023-04-30T09:11:06.020695+00:00 0:10:01.787572 370463 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-30T09:01:01.898287+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-30T08:00:00+00:00 EmrCreateJobFlowOperator 2023-04-30T09:00:42.073749+00:00 2023-04-30T09:00:42.978119+00:00 0:00:00.904370 370461 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-30T09:00:39.809992+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-30T08:00:00+00:00 PythonOperator 2023-04-30T09:00:18.063919+00:00 2023-04-30T09:00:19.102898+00:00 0:00:01.038979 370459 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-30T09:00:15.726970+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-30T07:00:00+00:00 TriggerDagRunOperator 2023-04-30T08:42:57.720058+00:00 2023-04-30T08:42:58.149170+00:00 0:00:00.429112 370451 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-30T08:42:55.292208+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-30T07:00:00+00:00 TriggerDagRunOperator 2023-04-30T08:42:57.629986+00:00 2023-04-30T08:42:57.966604+00:00 0:00:00.336618 370450 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-30T08:42:55.292237+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-30T07:00:00+00:00 EmrJobFlowSensor 2023-04-30T08:25:10.670830+00:00 2023-04-30T08:35:12.472685+00:00 0:10:01.801855 370446 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-30T08:25:08.427342+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-30T07:00:00+00:00 EmrCreateJobFlowOperator 2023-04-30T08:24:49.122673+00:00 2023-04-30T08:24:49.867281+00:00 0:00:00.744608 370443 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-30T08:24:46.401649+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-30T07:00:00+00:00 PythonOperator 2023-04-30T08:24:28.666522+00:00 2023-04-30T08:24:29.519293+00:00 0:00:00.852771 370440 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-30T08:24:26.393062+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-30T06:00:00+00:00 TriggerDagRunOperator 2023-04-30T07:14:39.854256+00:00 2023-04-30T07:14:40.190243+00:00 0:00:00.335987 370428 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-30T07:14:37.424549+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-30T06:00:00+00:00 TriggerDagRunOperator 2023-04-30T07:14:39.810279+00:00 2023-04-30T07:14:40.251690+00:00 0:00:00.441411 370427 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-30T07:14:37.424520+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-30T06:00:00+00:00 EmrJobFlowSensor 2023-04-30T07:02:22.964855+00:00 2023-04-30T07:12:24.710859+00:00 0:10:01.746004 370421 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-30T07:02:20.810352+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-30T06:00:00+00:00 EmrCreateJobFlowOperator 2023-04-30T07:02:00.945537+00:00 2023-04-30T07:02:01.916856+00:00 0:00:00.971319 370419 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-30T07:01:58.751414+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-30T06:00:00+00:00 PythonOperator 2023-04-30T07:01:40.905075+00:00 2023-04-30T07:01:41.750069+00:00 0:00:00.844994 370417 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-30T07:01:38.734429+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-30T05:00:00+00:00 TriggerDagRunOperator 2023-04-30T06:21:47.618388+00:00 2023-04-30T06:21:48.061044+00:00 0:00:00.442656 370404 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-30T06:21:44.705618+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-30T05:00:00+00:00 TriggerDagRunOperator 2023-04-30T06:21:47.549568+00:00 2023-04-30T06:21:47.876846+00:00 0:00:00.327278 370403 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-30T06:21:44.705575+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-30T05:00:00+00:00 EmrJobFlowSensor 2023-04-30T06:11:29.901933+00:00 2023-04-30T06:21:31.809594+00:00 0:10:01.907661 370399 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-30T06:11:27.299949+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-30T05:00:00+00:00 EmrCreateJobFlowOperator 2023-04-30T06:11:07.374633+00:00 2023-04-30T06:11:08.204582+00:00 0:00:00.829949 370395 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-30T06:11:05.223807+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-30T05:00:00+00:00 PythonOperator 2023-04-30T06:10:48.447539+00:00 2023-04-30T06:10:49.412104+00:00 0:00:00.964565 370393 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-30T06:10:45.211189+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-30T04:00:00+00:00 TriggerDagRunOperator 2023-04-30T05:31:46.457465+00:00 2023-04-30T05:31:46.843783+00:00 0:00:00.386318 370383 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-30T05:31:43.828657+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-30T04:00:00+00:00 TriggerDagRunOperator 2023-04-30T05:31:46.431666+00:00 2023-04-30T05:31:46.920835+00:00 0:00:00.489169 370382 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-30T05:31:43.828627+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-30T04:00:00+00:00 EmrJobFlowSensor 2023-04-30T05:20:27.031939+00:00 2023-04-30T05:30:28.890857+00:00 0:10:01.858918 370377 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-30T05:20:24.810156+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-30T04:00:00+00:00 EmrCreateJobFlowOperator 2023-04-30T05:20:05.047564+00:00 2023-04-30T05:20:05.826155+00:00 0:00:00.778591 370375 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-30T05:20:02.763608+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-30T04:00:00+00:00 PythonOperator 2023-04-30T05:19:45.632082+00:00 2023-04-30T05:19:46.479855+00:00 0:00:00.847773 370372 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-30T05:19:42.798657+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-30T03:00:00+00:00 TriggerDagRunOperator 2023-04-30T04:23:57.759735+00:00 2023-04-30T04:23:58.228569+00:00 0:00:00.468834 370359 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-30T04:23:54.338388+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-30T03:00:00+00:00 TriggerDagRunOperator 2023-04-30T04:23:57.006849+00:00 2023-04-30T04:23:57.472583+00:00 0:00:00.465734 370358 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-30T04:23:54.338422+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-30T03:00:00+00:00 EmrJobFlowSensor 2023-04-30T04:04:38.464661+00:00 2023-04-30T04:14:40.413102+00:00 0:10:01.948441 370352 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-30T04:04:35.889067+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-30T03:00:00+00:00 EmrCreateJobFlowOperator 2023-04-30T04:04:18.012822+00:00 2023-04-30T04:04:18.925831+00:00 0:00:00.913009 370350 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-30T04:04:15.828718+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-30T03:00:00+00:00 PythonOperator 2023-04-30T04:03:56.819958+00:00 2023-04-30T04:03:57.810846+00:00 0:00:00.990888 370348 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-30T04:03:53.816314+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-30T02:00:00+00:00 TriggerDagRunOperator 2023-04-30T03:19:00.164811+00:00 2023-04-30T03:19:00.598290+00:00 0:00:00.433479 370338 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-30T03:18:56.809850+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-30T02:00:00+00:00 TriggerDagRunOperator 2023-04-30T03:18:59.866924+00:00 2023-04-30T03:19:00.541824+00:00 0:00:00.674900 370337 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-30T03:18:56.809907+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-30T02:00:00+00:00 EmrJobFlowSensor 2023-04-30T03:00:48.187791+00:00 2023-04-30T03:10:49.954720+00:00 0:10:01.766929 370330 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-30T03:00:45.902377+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-30T02:00:00+00:00 EmrCreateJobFlowOperator 2023-04-30T03:00:26.050930+00:00 2023-04-30T03:00:26.904316+00:00 0:00:00.853386 370328 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-30T03:00:23.807254+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-30T02:00:00+00:00 PythonOperator 2023-04-30T03:00:06.193812+00:00 2023-04-30T03:00:07.067309+00:00 0:00:00.873497 370326 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-30T03:00:03.793261+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-30T01:00:00+00:00 TriggerDagRunOperator 2023-04-30T02:11:38.754151+00:00 2023-04-30T02:11:39.133699+00:00 0:00:00.379548 370313 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-30T02:11:36.332202+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-30T01:00:00+00:00 TriggerDagRunOperator 2023-04-30T02:11:38.747054+00:00 2023-04-30T02:11:39.215784+00:00 0:00:00.468730 370312 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-30T02:11:36.332174+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-30T01:00:00+00:00 EmrJobFlowSensor 2023-04-30T02:01:16.358446+00:00 2023-04-30T02:11:18.243888+00:00 0:10:01.885442 370305 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-30T02:01:13.389498+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-30T01:00:00+00:00 EmrCreateJobFlowOperator 2023-04-30T02:00:53.433090+00:00 2023-04-30T02:00:54.226065+00:00 0:00:00.792975 370303 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-30T02:00:51.276513+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-30T01:00:00+00:00 PythonOperator 2023-04-30T02:00:33.559524+00:00 2023-04-30T02:00:34.460578+00:00 0:00:00.901054 370301 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-30T02:00:31.258051+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-30T00:00:00+00:00 TriggerDagRunOperator 2023-04-30T01:25:48.154217+00:00 2023-04-30T01:25:48.697228+00:00 0:00:00.543011 370283 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-30T01:25:45.951697+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-30T00:00:00+00:00 TriggerDagRunOperator 2023-04-30T01:25:48.130637+00:00 2023-04-30T01:25:48.534482+00:00 0:00:00.403845 370282 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-30T01:25:45.951660+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-30T00:00:00+00:00 EmrJobFlowSensor 2023-04-30T01:00:47.577800+00:00 2023-04-30T01:10:49.534618+00:00 0:10:01.956818 370277 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-30T01:00:45.278390+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-30T00:00:00+00:00 EmrCreateJobFlowOperator 2023-04-30T01:00:25.697308+00:00 2023-04-30T01:00:26.858929+00:00 0:00:01.161621 370275 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-30T01:00:23.288067+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-30T00:00:00+00:00 PythonOperator 2023-04-30T01:00:04.217279+00:00 2023-04-30T01:00:05.175085+00:00 0:00:00.957806 370273 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-30T01:00:01.289617+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-29T23:00:00+00:00 TriggerDagRunOperator 2023-04-30T00:17:15.952597+00:00 2023-04-30T00:17:16.397741+00:00 0:00:00.445144 370262 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-30T00:17:12.929668+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-29T23:00:00+00:00 TriggerDagRunOperator 2023-04-30T00:17:15.844812+00:00 2023-04-30T00:17:16.208465+00:00 0:00:00.363653 370261 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-30T00:17:12.929704+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-29T23:00:00+00:00 EmrJobFlowSensor 2023-04-30T00:03:24.162090+00:00 2023-04-30T00:13:25.979915+00:00 0:10:01.817825 370255 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-30T00:03:21.597929+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-29T23:00:00+00:00 EmrCreateJobFlowOperator 2023-04-30T00:03:03.735763+00:00 2023-04-30T00:03:04.564937+00:00 0:00:00.829174 370253 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-30T00:03:01.517497+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-29T23:00:00+00:00 PythonOperator 2023-04-30T00:02:42.909457+00:00 2023-04-30T00:02:43.794776+00:00 0:00:00.885319 370251 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-30T00:02:39.457614+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-29T22:00:00+00:00 TriggerDagRunOperator 2023-04-29T23:16:38.016847+00:00 2023-04-29T23:16:38.458734+00:00 0:00:00.441887 370239 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-29T23:16:35.511309+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-29T22:00:00+00:00 TriggerDagRunOperator 2023-04-29T23:16:37.909865+00:00 2023-04-29T23:16:38.277937+00:00 0:00:00.368072 370238 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-29T23:16:35.511261+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-29T22:00:00+00:00 EmrJobFlowSensor 2023-04-29T23:16:15.893485+00:00 2023-04-29T23:16:16.389822+00:00 0:00:00.496337 370237 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-29T23:16:13.501536+00:00 3 default_pool