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-03-01T09:00:00+00:00 EmrJobFlowSensor 2023-03-01T10:00:48.315865+00:00 2023-03-01T10:10:50.099579+00:00 0:10:01.783714 346871 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-01T10:00:46.089504+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-01T09:00:00+00:00 EmrCreateJobFlowOperator 2023-03-01T10:00:28.412538+00:00 2023-03-01T10:00:29.259709+00:00 0:00:00.847171 346869 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-01T10:00:26.079691+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-01T09:00:00+00:00 PythonOperator 2023-03-01T10:00:04.904661+00:00 2023-03-01T10:00:08.981332+00:00 0:00:04.076671 346867 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-01T10:00:02.106359+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-01T08:00:00+00:00 TriggerDagRunOperator 2023-03-01T09:26:59.315997+00:00 2023-03-01T09:26:59.833297+00:00 0:00:00.517300 346860 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-01T09:26:56.310791+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-01T08:00:00+00:00 TriggerDagRunOperator 2023-03-01T09:26:59.134120+00:00 2023-03-01T09:26:59.609624+00:00 0:00:00.475504 346859 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-01T09:26:56.310826+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-01T08:00:00+00:00 EmrJobFlowSensor 2023-03-01T09:02:03.645739+00:00 2023-03-01T09:13:05.672206+00:00 0:11:02.026467 346852 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-01T09:02:01.149445+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-01T08:00:00+00:00 EmrCreateJobFlowOperator 2023-03-01T09:01:42.067936+00:00 2023-03-01T09:01:42.966766+00:00 0:00:00.898830 346850 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-01T09:01:39.179579+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-01T08:00:00+00:00 PythonOperator 2023-03-01T09:00:23.586764+00:00 2023-03-01T09:00:26.584124+00:00 0:00:02.997360 346848 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-01T09:00:21.274751+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-01T07:00:00+00:00 TriggerDagRunOperator 2023-03-01T08:27:46.650961+00:00 2023-03-01T08:27:47.145238+00:00 0:00:00.494277 346839 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-01T08:27:44.282894+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-01T07:00:00+00:00 TriggerDagRunOperator 2023-03-01T08:27:46.629340+00:00 2023-03-01T08:27:47.132598+00:00 0:00:00.503258 346838 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-01T08:27:44.282924+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-01T07:00:00+00:00 EmrJobFlowSensor 2023-03-01T08:17:40.304373+00:00 2023-03-01T08:27:42.143050+00:00 0:10:01.838677 346833 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-01T08:17:38.001655+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-01T07:00:00+00:00 EmrCreateJobFlowOperator 2023-03-01T08:17:18.208803+00:00 2023-03-01T08:17:19.494714+00:00 0:00:01.285911 346830 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-01T08:17:15.991901+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-01T07:00:00+00:00 PythonOperator 2023-03-01T08:16:58.663614+00:00 2023-03-01T08:17:04.141855+00:00 0:00:05.478241 346828 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-01T08:16:55.973677+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-01T06:00:00+00:00 TriggerDagRunOperator 2023-03-01T07:11:22.242919+00:00 2023-03-01T07:11:22.766063+00:00 0:00:00.523144 346817 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-01T07:11:19.492705+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-01T06:00:00+00:00 TriggerDagRunOperator 2023-03-01T07:11:22.050021+00:00 2023-03-01T07:11:22.511735+00:00 0:00:00.461714 346816 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-01T07:11:19.492738+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-01T06:00:00+00:00 EmrJobFlowSensor 2023-03-01T07:01:04.203686+00:00 2023-03-01T07:11:06.021253+00:00 0:10:01.817567 346809 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-01T07:01:01.989290+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-01T06:00:00+00:00 EmrCreateJobFlowOperator 2023-03-01T07:00:42.458951+00:00 2023-03-01T07:00:44.076637+00:00 0:00:01.617686 346807 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-01T07:00:39.944205+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-01T06:00:00+00:00 PythonOperator 2023-03-01T07:00:20.571259+00:00 2023-03-01T07:00:25.719234+00:00 0:00:05.147975 346805 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-01T07:00:17.924575+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-01T05:00:00+00:00 TriggerDagRunOperator 2023-03-01T06:12:45.351741+00:00 2023-03-01T06:12:45.972414+00:00 0:00:00.620673 346796 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-01T06:12:42.048267+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-01T05:00:00+00:00 TriggerDagRunOperator 2023-03-01T06:12:44.716714+00:00 2023-03-01T06:12:45.582927+00:00 0:00:00.866213 346795 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-01T06:12:42.048239+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-01T05:00:00+00:00 EmrJobFlowSensor 2023-03-01T06:00:53.550403+00:00 2023-03-01T06:10:55.336246+00:00 0:10:01.785843 346788 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-01T06:00:51.047558+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-01T05:00:00+00:00 EmrCreateJobFlowOperator 2023-03-01T06:00:36.146680+00:00 2023-03-01T06:00:37.007249+00:00 0:00:00.860569 346786 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-01T06:00:31.095254+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-01T05:00:00+00:00 PythonOperator 2023-03-01T06:00:12.251360+00:00 2023-03-01T06:00:15.658127+00:00 0:00:03.406767 346784 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-01T06:00:09.033325+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-01T04:00:00+00:00 TriggerDagRunOperator 2023-03-01T05:18:43.062762+00:00 2023-03-01T05:18:43.625871+00:00 0:00:00.563109 346774 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-01T05:18:39.976974+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-01T04:00:00+00:00 TriggerDagRunOperator 2023-03-01T05:18:42.715561+00:00 2023-03-01T05:18:43.208958+00:00 0:00:00.493397 346773 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-01T05:18:39.977002+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-01T04:00:00+00:00 EmrJobFlowSensor 2023-03-01T05:08:25.577852+00:00 2023-03-01T05:18:27.459749+00:00 0:10:01.881897 346770 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-01T05:08:23.337463+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-01T04:00:00+00:00 EmrCreateJobFlowOperator 2023-03-01T05:08:03.999590+00:00 2023-03-01T05:08:04.864030+00:00 0:00:00.864440 346767 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-01T05:08:01.272861+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-01T04:00:00+00:00 PythonOperator 2023-03-01T05:07:41.582466+00:00 2023-03-01T05:07:44.569075+00:00 0:00:02.986609 346764 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-01T05:07:39.240413+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-01T03:00:00+00:00 TriggerDagRunOperator 2023-03-01T04:13:41.454586+00:00 2023-03-01T04:13:42.197819+00:00 0:00:00.743233 346753 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-01T04:13:38.303086+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-01T03:00:00+00:00 TriggerDagRunOperator 2023-03-01T04:13:41.000261+00:00 2023-03-01T04:13:41.951009+00:00 0:00:00.950748 346752 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-01T04:13:38.303126+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-01T03:00:00+00:00 EmrJobFlowSensor 2023-03-01T04:03:17.038534+00:00 2023-03-01T04:13:18.903294+00:00 0:10:01.864760 346746 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-01T04:03:14.533064+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-01T03:00:00+00:00 EmrCreateJobFlowOperator 2023-03-01T04:02:57.013161+00:00 2023-03-01T04:02:58.127560+00:00 0:00:01.114399 346744 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-01T04:02:52.467800+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-01T03:00:00+00:00 PythonOperator 2023-03-01T04:02:32.668091+00:00 2023-03-01T04:02:37.187161+00:00 0:00:04.519070 346742 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-01T04:02:30.446330+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-01T02:00:00+00:00 TriggerDagRunOperator 2023-03-01T03:28:08.134423+00:00 2023-03-01T03:28:08.631437+00:00 0:00:00.497014 346734 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-01T03:28:05.564130+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-01T02:00:00+00:00 TriggerDagRunOperator 2023-03-01T03:28:08.116776+00:00 2023-03-01T03:28:08.605876+00:00 0:00:00.489100 346733 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-01T03:28:05.564101+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-01T02:00:00+00:00 EmrJobFlowSensor 2023-03-01T03:15:41.216742+00:00 2023-03-01T03:25:42.973455+00:00 0:10:01.756713 346730 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-01T03:15:38.649304+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-01T02:00:00+00:00 EmrCreateJobFlowOperator 2023-03-01T03:15:21.231813+00:00 2023-03-01T03:15:22.100694+00:00 0:00:00.868881 346727 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-01T03:15:18.631135+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-01T02:00:00+00:00 PythonOperator 2023-03-01T03:14:58.845976+00:00 2023-03-01T03:15:03.872743+00:00 0:00:05.026767 346724 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-01T03:14:56.616730+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-01T01:00:00+00:00 TriggerDagRunOperator 2023-03-01T02:39:43.480825+00:00 2023-03-01T02:39:44.517398+00:00 0:00:01.036573 346715 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-01T02:39:41.047877+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-01T01:00:00+00:00 TriggerDagRunOperator 2023-03-01T02:39:43.448862+00:00 2023-03-01T02:39:44.506668+00:00 0:00:01.057806 346714 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-01T02:39:41.047848+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-01T01:00:00+00:00 EmrJobFlowSensor 2023-03-01T02:00:58.642928+00:00 2023-03-01T02:11:00.459729+00:00 0:10:01.816801 346707 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-01T02:00:56.460013+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-01T01:00:00+00:00 EmrCreateJobFlowOperator 2023-03-01T02:00:35.051131+00:00 2023-03-01T02:00:36.047189+00:00 0:00:00.996058 346705 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-01T02:00:32.507556+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-01T01:00:00+00:00 PythonOperator 2023-03-01T02:00:12.915122+00:00 2023-03-01T02:00:16.004083+00:00 0:00:03.088961 346703 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-01T02:00:10.410210+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-01T00:00:00+00:00 TriggerDagRunOperator 2023-03-01T01:58:29.251584+00:00 2023-03-01T01:58:30.216966+00:00 0:00:00.965382 346692 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-01T01:58:26.148289+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-01T00:00:00+00:00 TriggerDagRunOperator 2023-03-01T01:58:29.062197+00:00 2023-03-01T01:58:29.557927+00:00 0:00:00.495730 346691 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-01T01:58:26.148318+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-01T00:00:00+00:00 EmrJobFlowSensor 2023-03-01T01:10:18.686175+00:00 2023-03-01T01:20:20.545753+00:00 0:10:01.859578 346686 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-01T01:10:16.279213+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-01T00:00:00+00:00 EmrCreateJobFlowOperator 2023-03-01T01:09:58.569059+00:00 2023-03-01T01:09:59.738944+00:00 0:00:01.169885 346683 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-01T01:09:56.261458+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-01T00:00:00+00:00 PythonOperator 2023-03-01T01:09:37.038672+00:00 2023-03-01T01:09:43.435069+00:00 0:00:06.396397 346680 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-01T01:09:34.248612+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-28T23:00:00+00:00 TriggerDagRunOperator 2023-03-01T00:23:16.762974+00:00 2023-03-01T00:23:17.273870+00:00 0:00:00.510896 346672 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-01T00:23:13.753441+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-28T23:00:00+00:00 TriggerDagRunOperator 2023-03-01T00:23:16.121545+00:00 2023-03-01T00:23:16.568589+00:00 0:00:00.447044 346671 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-01T00:23:13.753414+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-28T23:00:00+00:00 EmrJobFlowSensor 2023-03-01T00:01:06.692325+00:00 2023-03-01T00:11:08.801998+00:00 0:10:02.109673 346667 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-01T00:01:03.869458+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-28T23:00:00+00:00 EmrCreateJobFlowOperator 2023-03-01T00:00:46.830541+00:00 2023-03-01T00:00:47.706800+00:00 0:00:00.876259 346665 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-01T00:00:41.756757+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-28T23:00:00+00:00 PythonOperator 2023-03-01T00:00:21.988878+00:00 2023-03-01T00:00:25.822694+00:00 0:00:03.833816 346663 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-01T00:00:19.736393+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-28T22:00:00+00:00 TriggerDagRunOperator 2023-02-28T23:16:44.424000+00:00 2023-02-28T23:16:45.461701+00:00 0:00:01.037701 346653 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-28T23:16:41.656789+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-28T22:00:00+00:00 TriggerDagRunOperator 2023-02-28T23:16:44.421230+00:00 2023-02-28T23:16:45.398558+00:00 0:00:00.977328 346652 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-28T23:16:41.656760+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-28T22:00:00+00:00 EmrJobFlowSensor 2023-02-28T23:06:28.819178+00:00 2023-02-28T23:16:30.633086+00:00 0:10:01.813908 346649 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-28T23:06:26.544184+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-28T22:00:00+00:00 EmrCreateJobFlowOperator 2023-02-28T23:06:07.390569+00:00 2023-02-28T23:06:08.259412+00:00 0:00:00.868843 346645 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-28T23:06:04.526138+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-28T22:00:00+00:00 PythonOperator 2023-02-28T23:05:46.979389+00:00 2023-02-28T23:05:51.069970+00:00 0:00:04.090581 346640 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-28T23:05:44.615366+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-28T21:00:00+00:00 TriggerDagRunOperator 2023-02-28T22:18:17.243536+00:00 2023-02-28T22:18:17.763698+00:00 0:00:00.520162 346630 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-28T22:18:14.433618+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-28T21:00:00+00:00 TriggerDagRunOperator 2023-02-28T22:18:17.212172+00:00 2023-02-28T22:18:17.695691+00:00 0:00:00.483519 346629 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-28T22:18:14.433647+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-28T21:00:00+00:00 EmrJobFlowSensor 2023-02-28T22:00:48.797581+00:00 2023-02-28T22:10:50.649234+00:00 0:10:01.851653 346621 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-28T22:00:46.466469+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-28T21:00:00+00:00 EmrCreateJobFlowOperator 2023-02-28T22:00:26.695089+00:00 2023-02-28T22:00:27.529532+00:00 0:00:00.834443 346619 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-28T22:00:24.469792+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-28T21:00:00+00:00 PythonOperator 2023-02-28T22:00:04.795142+00:00 2023-02-28T22:00:07.853542+00:00 0:00:03.058400 346617 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-28T22:00:02.427849+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-28T20:00:00+00:00 TriggerDagRunOperator 2023-02-28T21:11:18.925223+00:00 2023-02-28T21:11:19.417638+00:00 0:00:00.492415 346607 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-28T21:11:16.295618+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-28T20:00:00+00:00 TriggerDagRunOperator 2023-02-28T21:11:18.588015+00:00 2023-02-28T21:11:19.085305+00:00 0:00:00.497290 346606 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-28T21:11:16.295586+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-28T20:00:00+00:00 EmrJobFlowSensor 2023-02-28T21:00:50.352721+00:00 2023-02-28T21:10:52.171893+00:00 0:10:01.819172 346599 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-28T21:00:48.179896+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-28T20:00:00+00:00 EmrCreateJobFlowOperator 2023-02-28T21:00:28.433463+00:00 2023-02-28T21:00:29.340337+00:00 0:00:00.906874 346597 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-28T21:00:26.134180+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-28T20:00:00+00:00 PythonOperator 2023-02-28T21:00:08.503949+00:00 2023-02-28T21:00:11.530079+00:00 0:00:03.026130 346595 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-28T21:00:06.076614+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-28T19:00:00+00:00 TriggerDagRunOperator 2023-02-28T20:17:29.872633+00:00 2023-02-28T20:17:30.414840+00:00 0:00:00.542207 346585 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-28T20:17:27.233630+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-28T19:00:00+00:00 TriggerDagRunOperator 2023-02-28T20:17:29.708943+00:00 2023-02-28T20:17:30.286249+00:00 0:00:00.577306 346584 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-28T20:17:27.233588+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-28T19:00:00+00:00 EmrJobFlowSensor 2023-02-28T20:07:22.675699+00:00 2023-02-28T20:17:24.536315+00:00 0:10:01.860616 346580 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-28T20:07:20.280205+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-28T19:00:00+00:00 EmrCreateJobFlowOperator 2023-02-28T20:07:00.843790+00:00 2023-02-28T20:07:01.970469+00:00 0:00:01.126679 346577 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-28T20:06:58.258743+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-28T19:00:00+00:00 PythonOperator 2023-02-28T20:06:40.616085+00:00 2023-02-28T20:06:43.962224+00:00 0:00:03.346139 346574 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-28T20:06:38.243146+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-28T18:00:00+00:00 TriggerDagRunOperator 2023-02-28T19:11:57.212786+00:00 2023-02-28T19:11:57.793757+00:00 0:00:00.580971 346564 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-28T19:11:54.181258+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-28T18:00:00+00:00 TriggerDagRunOperator 2023-02-28T19:11:56.994286+00:00 2023-02-28T19:11:57.498274+00:00 0:00:00.503988 346563 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-28T19:11:54.181287+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-28T18:00:00+00:00 EmrJobFlowSensor 2023-02-28T19:01:06.595695+00:00 2023-02-28T19:11:08.394827+00:00 0:10:01.799132 346556 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-28T19:01:04.357058+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-28T18:00:00+00:00 EmrCreateJobFlowOperator 2023-02-28T19:00:44.930103+00:00 2023-02-28T19:00:46.138905+00:00 0:00:01.208802 346554 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-28T19:00:42.351968+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-28T18:00:00+00:00 PythonOperator 2023-02-28T19:00:24.575584+00:00 2023-02-28T19:00:28.652496+00:00 0:00:04.076912 346552 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-28T19:00:22.313072+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-28T17:00:00+00:00 TriggerDagRunOperator 2023-02-28T18:12:18.054019+00:00 2023-02-28T18:12:18.621277+00:00 0:00:00.567258 346544 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-28T18:12:15.338386+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-28T17:00:00+00:00 TriggerDagRunOperator 2023-02-28T18:12:17.899721+00:00 2023-02-28T18:12:18.487295+00:00 0:00:00.587574 346543 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-28T18:12:15.338416+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-28T17:00:00+00:00 EmrJobFlowSensor 2023-02-28T18:00:53.985499+00:00 2023-02-28T18:10:55.774213+00:00 0:10:01.788714 346535 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-28T18:00:51.695403+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-28T17:00:00+00:00 EmrCreateJobFlowOperator 2023-02-28T18:00:32.306136+00:00 2023-02-28T18:00:33.183086+00:00 0:00:00.876950 346533 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-28T18:00:29.611511+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-28T17:00:00+00:00 PythonOperator 2023-02-28T18:00:09.984356+00:00 2023-02-28T18:00:13.046922+00:00 0:00:03.062566 346531 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-28T18:00:07.525252+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-28T16:00:00+00:00 TriggerDagRunOperator 2023-02-28T17:27:31.132798+00:00 2023-02-28T17:27:31.662231+00:00 0:00:00.529433 346524 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-28T17:27:28.491371+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-28T16:00:00+00:00 TriggerDagRunOperator 2023-02-28T17:27:30.857149+00:00 2023-02-28T17:27:31.411009+00:00 0:00:00.553860 346523 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-28T17:27:28.491399+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-28T16:00:00+00:00 EmrJobFlowSensor 2023-02-28T17:17:05.442604+00:00 2023-02-28T17:27:07.210519+00:00 0:10:01.767915 346519 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-28T17:17:03.221396+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-28T16:00:00+00:00 EmrCreateJobFlowOperator 2023-02-28T17:16:43.532513+00:00 2023-02-28T17:16:44.559971+00:00 0:00:01.027458 346516 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-28T17:16:41.200411+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-28T16:00:00+00:00 PythonOperator 2023-02-28T17:16:23.682714+00:00 2023-02-28T17:16:27.582995+00:00 0:00:03.900281 346513 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-28T17:16:21.214331+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-28T15:00:00+00:00 TriggerDagRunOperator 2023-02-28T16:11:05.782447+00:00 2023-02-28T16:11:06.309197+00:00 0:00:00.526750 346501 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-28T16:11:03.378534+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-28T15:00:00+00:00 TriggerDagRunOperator 2023-02-28T16:11:05.637298+00:00 2023-02-28T16:11:06.195978+00:00 0:00:00.558680 346500 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-28T16:11:03.378503+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-28T15:00:00+00:00 EmrJobFlowSensor 2023-02-28T16:00:47.633068+00:00 2023-02-28T16:10:49.474794+00:00 0:10:01.841726 346493 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-28T16:00:45.307507+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-28T15:00:00+00:00 EmrCreateJobFlowOperator 2023-02-28T16:00:27.483161+00:00 2023-02-28T16:00:28.313417+00:00 0:00:00.830256 346491 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-28T16:00:25.176236+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-28T15:00:00+00:00 PythonOperator 2023-02-28T16:00:05.740373+00:00 2023-02-28T16:00:09.349255+00:00 0:00:03.608882 346489 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-28T16:00:03.153067+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-28T14:00:00+00:00 TriggerDagRunOperator 2023-02-28T15:39:54.818945+00:00 2023-02-28T15:39:55.340768+00:00 0:00:00.521823 346484 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-28T15:39:52.134951+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-28T14:00:00+00:00 TriggerDagRunOperator 2023-02-28T15:39:54.737434+00:00 2023-02-28T15:39:55.257130+00:00 0:00:00.519696 346483 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-28T15:39:52.134923+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-28T14:00:00+00:00 EmrJobFlowSensor 2023-02-28T15:26:23.425897+00:00 2023-02-28T15:36:25.187485+00:00 0:10:01.761588 346480 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-28T15:26:20.334195+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-28T14:00:00+00:00 EmrCreateJobFlowOperator 2023-02-28T15:26:00.998178+00:00 2023-02-28T15:26:02.024838+00:00 0:00:01.026660 346477 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-28T15:25:58.272108+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-28T14:00:00+00:00 PythonOperator 2023-02-28T15:25:38.776141+00:00 2023-02-28T15:25:43.012827+00:00 0:00:04.236686 346473 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-28T15:25:36.257366+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-28T13:00:00+00:00 TriggerDagRunOperator 2023-02-28T14:17:58.374151+00:00 2023-02-28T14:17:58.856575+00:00 0:00:00.482424 346465 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-28T14:17:55.427968+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-28T13:00:00+00:00 TriggerDagRunOperator 2023-02-28T14:17:58.210750+00:00 2023-02-28T14:17:58.675464+00:00 0:00:00.464714 346464 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-28T14:17:55.427931+00:00 2 default_pool