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 trigger_dagrun_booking-processing-job_v002 2023-04-06T07:00:00+00:00 TriggerDagRunOperator 2023-04-06T08:48:45.244022+00:00 2023-04-06T08:48:45.768965+00:00 0:00:00.524943 364834 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-06T08:48:42.251517+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-06T07:00:00+00:00 EmrJobFlowSensor 2023-04-06T08:25:14.943360+00:00 2023-04-06T08:35:16.721750+00:00 0:10:01.778390 364830 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-06T08:25:12.783354+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-06T07:00:00+00:00 EmrCreateJobFlowOperator 2023-04-06T08:24:53.391007+00:00 2023-04-06T08:24:54.414750+00:00 0:00:01.023743 364826 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-06T08:24:50.764906+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-06T07:00:00+00:00 PythonOperator 2023-04-06T08:24:32.688179+00:00 2023-04-06T08:24:38.712131+00:00 0:00:06.023952 364822 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-06T08:24:28.743347+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-06T06:00:00+00:00 TriggerDagRunOperator 2023-04-06T07:12:28.473655+00:00 2023-04-06T07:12:28.950622+00:00 0:00:00.476967 364810 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-06T07:12:25.123148+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-06T06:00:00+00:00 TriggerDagRunOperator 2023-04-06T07:12:28.096440+00:00 2023-04-06T07:12:28.566545+00:00 0:00:00.470105 364809 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-06T07:12:25.123188+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-06T06:00:00+00:00 EmrJobFlowSensor 2023-04-06T07:02:03.318632+00:00 2023-04-06T07:12:05.113531+00:00 0:10:01.794899 364802 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-06T07:02:01.117008+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-06T06:00:00+00:00 EmrCreateJobFlowOperator 2023-04-06T07:01:41.242204+00:00 2023-04-06T07:01:42.101284+00:00 0:00:00.859080 364800 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-06T07:01:39.095018+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-06T06:00:00+00:00 PythonOperator 2023-04-06T07:01:21.966418+00:00 2023-04-06T07:01:25.510331+00:00 0:00:03.543913 364798 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-06T07:01:19.035171+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-06T05:00:00+00:00 TriggerDagRunOperator 2023-04-06T06:11:17.126752+00:00 2023-04-06T06:11:17.598629+00:00 0:00:00.471877 364789 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-06T06:11:14.656390+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-06T05:00:00+00:00 TriggerDagRunOperator 2023-04-06T06:11:17.008015+00:00 2023-04-06T06:11:17.466798+00:00 0:00:00.458783 364788 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-06T06:11:14.656419+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-06T05:00:00+00:00 EmrJobFlowSensor 2023-04-06T06:00:59.883301+00:00 2023-04-06T06:11:01.636673+00:00 0:10:01.753372 364781 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-06T06:00:57.654948+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-06T05:00:00+00:00 EmrCreateJobFlowOperator 2023-04-06T06:00:40.450056+00:00 2023-04-06T06:00:41.822822+00:00 0:00:01.372766 364779 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-06T06:00:35.628600+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-06T05:00:00+00:00 PythonOperator 2023-04-06T06:00:15.785910+00:00 2023-04-06T06:00:19.430327+00:00 0:00:03.644417 364777 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-06T06:00:13.569429+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-06T04:00:00+00:00 TriggerDagRunOperator 2023-04-06T05:11:26.643760+00:00 2023-04-06T05:11:27.150119+00:00 0:00:00.506359 364768 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-06T05:11:23.916880+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-06T04:00:00+00:00 TriggerDagRunOperator 2023-04-06T05:11:26.555282+00:00 2023-04-06T05:11:27.057011+00:00 0:00:00.501729 364767 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-06T05:11:23.916921+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-06T04:00:00+00:00 EmrJobFlowSensor 2023-04-06T05:01:03.748719+00:00 2023-04-06T05:11:05.566946+00:00 0:10:01.818227 364761 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-06T05:01:00.887706+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-06T04:00:00+00:00 EmrCreateJobFlowOperator 2023-04-06T05:00:41.109815+00:00 2023-04-06T05:00:41.988815+00:00 0:00:00.879000 364758 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-06T05:00:38.798521+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-06T04:00:00+00:00 PythonOperator 2023-04-06T05:00:20.971986+00:00 2023-04-06T05:00:24.412976+00:00 0:00:03.440990 364757 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-06T05:00:18.691246+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-06T03:00:00+00:00 TriggerDagRunOperator 2023-04-06T04:11:11.859211+00:00 2023-04-06T04:11:12.390063+00:00 0:00:00.530852 364748 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-06T04:11:09.012597+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-06T03:00:00+00:00 TriggerDagRunOperator 2023-04-06T04:11:11.857318+00:00 2023-04-06T04:11:12.330997+00:00 0:00:00.473679 364747 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-06T04:11:09.012640+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-06T03:00:00+00:00 EmrJobFlowSensor 2023-04-06T04:00:52.693819+00:00 2023-04-06T04:10:54.479400+00:00 0:10:01.785581 364740 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-06T04:00:50.214731+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-06T03:00:00+00:00 EmrCreateJobFlowOperator 2023-04-06T04:00:30.517637+00:00 2023-04-06T04:00:31.421616+00:00 0:00:00.903979 364738 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-06T04:00:28.112052+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-06T03:00:00+00:00 PythonOperator 2023-04-06T04:00:08.633654+00:00 2023-04-06T04:00:12.718171+00:00 0:00:04.084517 364736 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-06T04:00:06.093514+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-06T02:00:00+00:00 TriggerDagRunOperator 2023-04-06T03:11:39.184133+00:00 2023-04-06T03:11:39.704232+00:00 0:00:00.520099 364728 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-06T03:11:36.501891+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-06T02:00:00+00:00 TriggerDagRunOperator 2023-04-06T03:11:38.996631+00:00 2023-04-06T03:11:39.461917+00:00 0:00:00.465286 364727 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-06T03:11:36.501848+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-06T02:00:00+00:00 EmrJobFlowSensor 2023-04-06T03:01:12.655873+00:00 2023-04-06T03:11:14.586718+00:00 0:10:01.930845 364720 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-06T03:01:10.279928+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-06T02:00:00+00:00 EmrCreateJobFlowOperator 2023-04-06T03:00:52.515783+00:00 2023-04-06T03:00:53.711637+00:00 0:00:01.195854 364718 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-06T03:00:50.261994+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-06T02:00:00+00:00 PythonOperator 2023-04-06T03:00:30.690242+00:00 2023-04-06T03:00:37.005681+00:00 0:00:06.315439 364716 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-06T03:00:28.245856+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-06T01:00:00+00:00 TriggerDagRunOperator 2023-04-06T02:15:01.947058+00:00 2023-04-06T02:15:02.443174+00:00 0:00:00.496116 364709 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-06T02:14:59.557878+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-06T01:00:00+00:00 TriggerDagRunOperator 2023-04-06T02:15:01.945255+00:00 2023-04-06T02:15:02.433727+00:00 0:00:00.488472 364708 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-06T02:14:59.557908+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-06T01:00:00+00:00 EmrJobFlowSensor 2023-04-06T02:01:43.105586+00:00 2023-04-06T02:11:44.993481+00:00 0:10:01.887895 364702 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-06T02:01:39.917653+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-06T01:00:00+00:00 EmrCreateJobFlowOperator 2023-04-06T02:01:20.265645+00:00 2023-04-06T02:01:21.154097+00:00 0:00:00.888452 364700 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-06T02:01:17.801947+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-06T01:00:00+00:00 PythonOperator 2023-04-06T02:01:00.345026+00:00 2023-04-06T02:01:04.082370+00:00 0:00:03.737344 364698 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-06T02:00:57.784559+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-06T00:00:00+00:00 TriggerDagRunOperator 2023-04-06T01:11:17.852576+00:00 2023-04-06T01:11:18.324161+00:00 0:00:00.471585 364684 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-06T01:11:15.439310+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-06T00:00:00+00:00 TriggerDagRunOperator 2023-04-06T01:11:17.631255+00:00 2023-04-06T01:11:18.102369+00:00 0:00:00.471114 364683 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-06T01:11:15.439278+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-06T00:00:00+00:00 EmrJobFlowSensor 2023-04-06T01:00:57.057083+00:00 2023-04-06T01:10:58.757132+00:00 0:10:01.700049 364677 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-06T01:00:54.864568+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-06T00:00:00+00:00 EmrCreateJobFlowOperator 2023-04-06T01:00:35.233042+00:00 2023-04-06T01:00:36.091249+00:00 0:00:00.858207 364675 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-06T01:00:32.843865+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-06T00:00:00+00:00 PythonOperator 2023-04-06T01:00:15.242767+00:00 2023-04-06T01:00:19.262933+00:00 0:00:04.020166 364673 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-06T01:00:12.802001+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-05T23:00:00+00:00 TriggerDagRunOperator 2023-04-06T00:22:32.671293+00:00 2023-04-06T00:22:33.133432+00:00 0:00:00.462139 364665 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-06T00:22:30.061965+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-05T23:00:00+00:00 TriggerDagRunOperator 2023-04-06T00:22:32.523982+00:00 2023-04-06T00:22:32.976490+00:00 0:00:00.452508 364664 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-06T00:22:30.061994+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-05T23:00:00+00:00 EmrJobFlowSensor 2023-04-06T00:09:59.349440+00:00 2023-04-06T00:20:01.910853+00:00 0:10:02.561413 364660 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-06T00:09:56.670629+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-05T23:00:00+00:00 EmrCreateJobFlowOperator 2023-04-06T00:09:36.828642+00:00 2023-04-06T00:09:38.110567+00:00 0:00:01.281925 364656 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-06T00:09:34.648881+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-05T23:00:00+00:00 PythonOperator 2023-04-06T00:09:14.855691+00:00 2023-04-06T00:09:22.731029+00:00 0:00:07.875338 364653 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-06T00:09:12.629998+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-05T22:00:00+00:00 TriggerDagRunOperator 2023-04-05T23:13:15.991162+00:00 2023-04-05T23:13:16.485940+00:00 0:00:00.494778 364640 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-05T23:13:12.981856+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-05T22:00:00+00:00 TriggerDagRunOperator 2023-04-05T23:13:15.806379+00:00 2023-04-05T23:13:16.294307+00:00 0:00:00.487928 364639 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-05T23:13:12.981890+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-05T22:00:00+00:00 EmrJobFlowSensor 2023-04-05T23:00:51.086029+00:00 2023-04-05T23:10:52.984659+00:00 0:10:01.898630 364636 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-05T23:00:48.640967+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-05T22:00:00+00:00 EmrCreateJobFlowOperator 2023-04-05T23:00:30.755651+00:00 2023-04-05T23:00:31.669770+00:00 0:00:00.914119 364633 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-05T23:00:28.623599+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-05T22:00:00+00:00 PythonOperator 2023-04-05T23:00:08.932635+00:00 2023-04-05T23:00:12.971755+00:00 0:00:04.039120 364629 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-05T23:00:06.596423+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-05T21:00:00+00:00 TriggerDagRunOperator 2023-04-05T22:10:21.330448+00:00 2023-04-05T22:10:21.823217+00:00 0:00:00.492769 364619 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-05T22:10:18.710041+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-05T21:00:00+00:00 TriggerDagRunOperator 2023-04-05T22:10:21.297917+00:00 2023-04-05T22:10:21.748260+00:00 0:00:00.450343 364618 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-05T22:10:18.710012+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-05T21:00:00+00:00 EmrJobFlowSensor 2023-04-05T22:01:10.693348+00:00 2023-04-05T22:10:12.272001+00:00 0:09:01.578653 364610 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-05T22:01:08.394658+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-05T21:00:00+00:00 EmrCreateJobFlowOperator 2023-04-05T22:00:26.673073+00:00 2023-04-05T22:00:27.509614+00:00 0:00:00.836541 364608 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-05T22:00:24.366159+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-05T21:00:00+00:00 PythonOperator 2023-04-05T22:00:06.669622+00:00 2023-04-05T22:00:10.798950+00:00 0:00:04.129328 364606 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-05T22:00:04.347113+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-05T20:00:00+00:00 TriggerDagRunOperator 2023-04-05T21:11:50.381367+00:00 2023-04-05T21:11:50.949659+00:00 0:00:00.568292 364596 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-05T21:11:47.689260+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-05T20:00:00+00:00 TriggerDagRunOperator 2023-04-05T21:11:50.330789+00:00 2023-04-05T21:11:50.795781+00:00 0:00:00.464992 364595 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-05T21:11:47.689232+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-05T20:00:00+00:00 EmrJobFlowSensor 2023-04-05T21:01:35.555874+00:00 2023-04-05T21:11:37.368098+00:00 0:10:01.812224 364590 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-05T21:01:33.352307+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-05T20:00:00+00:00 EmrCreateJobFlowOperator 2023-04-05T21:01:13.700300+00:00 2023-04-05T21:01:14.558747+00:00 0:00:00.858447 364588 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-05T21:01:11.329415+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-05T20:00:00+00:00 PythonOperator 2023-04-05T21:00:22.381823+00:00 2023-04-05T21:00:26.454392+00:00 0:00:04.072569 364584 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-05T21:00:20.228270+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-05T19:00:00+00:00 TriggerDagRunOperator 2023-04-05T20:13:54.133951+00:00 2023-04-05T20:13:54.649470+00:00 0:00:00.515519 364574 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-05T20:13:51.367046+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-05T19:00:00+00:00 TriggerDagRunOperator 2023-04-05T20:13:53.948059+00:00 2023-04-05T20:13:54.417027+00:00 0:00:00.468968 364573 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-05T20:13:51.367074+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-05T19:00:00+00:00 EmrJobFlowSensor 2023-04-05T20:03:47.599612+00:00 2023-04-05T20:13:49.220122+00:00 0:10:01.620510 364567 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-05T20:03:45.427548+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-05T19:00:00+00:00 EmrCreateJobFlowOperator 2023-04-05T20:03:27.650368+00:00 2023-04-05T20:03:28.526725+00:00 0:00:00.876357 364565 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-05T20:03:25.378983+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-05T19:00:00+00:00 PythonOperator 2023-04-05T20:03:05.723359+00:00 2023-04-05T20:03:08.948046+00:00 0:00:03.224687 364563 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-05T20:03:03.344967+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-05T18:00:00+00:00 TriggerDagRunOperator 2023-04-05T19:12:02.939250+00:00 2023-04-05T19:12:03.471393+00:00 0:00:00.532143 364552 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-05T19:12:00.017424+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-05T18:00:00+00:00 TriggerDagRunOperator 2023-04-05T19:12:02.625226+00:00 2023-04-05T19:12:03.105714+00:00 0:00:00.480488 364551 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-05T19:12:00.017392+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-05T18:00:00+00:00 EmrJobFlowSensor 2023-04-05T19:00:54.278737+00:00 2023-04-05T19:11:56.178485+00:00 0:11:01.899748 364544 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-05T19:00:52.047305+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-05T18:00:00+00:00 EmrCreateJobFlowOperator 2023-04-05T19:00:34.423805+00:00 2023-04-05T19:00:35.323527+00:00 0:00:00.899722 364542 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-05T19:00:32.025728+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-05T18:00:00+00:00 PythonOperator 2023-04-05T19:00:12.458230+00:00 2023-04-05T19:00:16.496578+00:00 0:00:04.038348 364540 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-05T19:00:10.007223+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-05T17:00:00+00:00 TriggerDagRunOperator 2023-04-05T18:14:46.787261+00:00 2023-04-05T18:14:47.271915+00:00 0:00:00.484654 364531 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-05T18:14:44.247247+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-05T17:00:00+00:00 TriggerDagRunOperator 2023-04-05T18:14:46.588029+00:00 2023-04-05T18:14:47.065395+00:00 0:00:00.477366 364530 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-05T18:14:44.247218+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-05T17:00:00+00:00 EmrJobFlowSensor 2023-04-05T18:04:27.326552+00:00 2023-04-05T18:14:29.081698+00:00 0:10:01.755146 364524 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-05T18:04:25.088312+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-05T17:00:00+00:00 EmrCreateJobFlowOperator 2023-04-05T18:04:07.296955+00:00 2023-04-05T18:04:08.557378+00:00 0:00:01.260423 364522 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-05T18:04:03.058019+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-05T17:00:00+00:00 PythonOperator 2023-04-05T18:03:45.377669+00:00 2023-04-05T18:03:49.909662+00:00 0:00:04.531993 364520 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-05T18:03:43.038206+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-05T16:00:00+00:00 TriggerDagRunOperator 2023-04-05T17:11:28.762857+00:00 2023-04-05T17:11:29.254553+00:00 0:00:00.491696 364511 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-05T17:11:26.527360+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-05T16:00:00+00:00 TriggerDagRunOperator 2023-04-05T17:11:28.731092+00:00 2023-04-05T17:11:29.178804+00:00 0:00:00.447712 364510 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-05T17:11:26.527388+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-05T16:00:00+00:00 EmrJobFlowSensor 2023-04-05T17:01:03.342619+00:00 2023-04-05T17:11:05.131609+00:00 0:10:01.788990 364504 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-05T17:01:00.988031+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-05T16:00:00+00:00 EmrCreateJobFlowOperator 2023-04-05T17:00:43.208935+00:00 2023-04-05T17:00:44.025368+00:00 0:00:00.816433 364502 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-05T17:00:41.005279+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-05T16:00:00+00:00 PythonOperator 2023-04-05T17:00:21.327432+00:00 2023-04-05T17:00:24.567181+00:00 0:00:03.239749 364500 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-05T17:00:18.948984+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-05T15:00:00+00:00 TriggerDagRunOperator 2023-04-05T16:22:01.534832+00:00 2023-04-05T16:22:02.071299+00:00 0:00:00.536467 364491 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-05T16:21:58.311300+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-05T15:00:00+00:00 TriggerDagRunOperator 2023-04-05T16:22:01.348427+00:00 2023-04-05T16:22:01.839420+00:00 0:00:00.490993 364490 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-05T16:21:58.311253+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-05T15:00:00+00:00 EmrJobFlowSensor 2023-04-05T16:09:38.727569+00:00 2023-04-05T16:19:40.687102+00:00 0:10:01.959533 364486 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-05T16:09:36.226735+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-05T15:00:00+00:00 EmrCreateJobFlowOperator 2023-04-05T16:09:16.295223+00:00 2023-04-05T16:09:17.160568+00:00 0:00:00.865345 364483 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-05T16:09:14.167001+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-05T15:00:00+00:00 PythonOperator 2023-04-05T16:08:58.446997+00:00 2023-04-05T16:09:03.865951+00:00 0:00:05.418954 364480 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-05T16:08:52.152895+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-05T14:00:00+00:00 TriggerDagRunOperator 2023-04-05T15:15:17.055388+00:00 2023-04-05T15:15:17.514403+00:00 0:00:00.459015 364470 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-05T15:15:14.812881+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-05T14:00:00+00:00 TriggerDagRunOperator 2023-04-05T15:15:16.942042+00:00 2023-04-05T15:15:17.391338+00:00 0:00:00.449296 364469 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-05T15:15:14.812844+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-05T14:00:00+00:00 EmrJobFlowSensor 2023-04-05T15:01:02.196113+00:00 2023-04-05T15:11:04.082043+00:00 0:10:01.885930 364465 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-05T15:00:59.750524+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-05T14:00:00+00:00 EmrCreateJobFlowOperator 2023-04-05T15:00:43.111306+00:00 2023-04-05T15:00:44.452920+00:00 0:00:01.341614 364463 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-05T15:00:37.731618+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-05T14:00:00+00:00 PythonOperator 2023-04-05T15:00:15.974879+00:00 2023-04-05T15:00:19.559157+00:00 0:00:03.584278 364461 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-05T15:00:13.670397+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-05T13:00:00+00:00 TriggerDagRunOperator 2023-04-05T14:29:04.149439+00:00 2023-04-05T14:29:04.652309+00:00 0:00:00.502870 364453 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-05T14:29:01.244705+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-05T13:00:00+00:00 TriggerDagRunOperator 2023-04-05T14:29:03.812176+00:00 2023-04-05T14:29:04.283316+00:00 0:00:00.471140 364452 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-05T14:29:01.244677+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-05T13:00:00+00:00 EmrJobFlowSensor 2023-04-05T14:15:49.664353+00:00 2023-04-05T14:25:51.507369+00:00 0:10:01.843016 364449 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-05T14:15:47.287801+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-05T13:00:00+00:00 EmrCreateJobFlowOperator 2023-04-05T14:15:27.473179+00:00 2023-04-05T14:15:28.327384+00:00 0:00:00.854205 364445 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-05T14:15:25.269147+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-05T13:00:00+00:00 PythonOperator 2023-04-05T14:15:07.787651+00:00 2023-04-05T14:15:11.173442+00:00 0:00:03.385791 364443 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-05T14:15:05.257161+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-05T12:00:00+00:00 TriggerDagRunOperator 2023-04-05T13:42:23.779822+00:00 2023-04-05T13:42:24.278840+00:00 0:00:00.499018 364435 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-05T13:42:21.041870+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-05T12:00:00+00:00 TriggerDagRunOperator 2023-04-05T13:42:23.592944+00:00 2023-04-05T13:42:24.072537+00:00 0:00:00.479593 364434 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-05T13:42:21.041842+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-05T12:00:00+00:00 EmrJobFlowSensor 2023-04-05T13:25:12.080117+00:00 2023-04-05T13:35:13.926493+00:00 0:10:01.846376 364429 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-05T13:25:09.716786+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-05T12:00:00+00:00 EmrCreateJobFlowOperator 2023-04-05T13:24:52.281647+00:00 2023-04-05T13:24:53.164939+00:00 0:00:00.883292 364427 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-05T13:24:49.701212+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-05T12:00:00+00:00 PythonOperator 2023-04-05T13:24:30.945418+00:00 2023-04-05T13:24:43.655692+00:00 0:00:12.710274 364423 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-05T13:24:27.734462+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-05T11:00:00+00:00 TriggerDagRunOperator 2023-04-05T12:41:21.245778+00:00 2023-04-05T12:41:21.715430+00:00 0:00:00.469652 364417 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-05T12:41:18.659200+00:00 2 default_pool