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_campaign-history-job_v002 2023-03-25T15:00:00+00:00 TriggerDagRunOperator 2023-03-25T16:45:25.847648+00:00 2023-03-25T16:45:26.492028+00:00 0:00:00.644380 359044 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-25T16:45:22.944170+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-25T15:00:00+00:00 EmrJobFlowSensor 2023-03-25T16:15:40.748079+00:00 2023-03-25T16:25:42.527071+00:00 0:10:01.778992 359041 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-25T16:15:38.544419+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-25T15:00:00+00:00 EmrCreateJobFlowOperator 2023-03-25T16:15:18.625564+00:00 2023-03-25T16:15:19.425026+00:00 0:00:00.799462 359038 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-25T16:15:16.520680+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-25T15:00:00+00:00 PythonOperator 2023-03-25T16:14:58.667824+00:00 2023-03-25T16:15:02.742665+00:00 0:00:04.074841 359035 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-25T16:14:56.500042+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-25T14:00:00+00:00 TriggerDagRunOperator 2023-03-25T15:23:13.569646+00:00 2023-03-25T15:23:14.095567+00:00 0:00:00.525921 359027 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-25T15:23:10.676348+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-25T14:00:00+00:00 TriggerDagRunOperator 2023-03-25T15:23:13.379811+00:00 2023-03-25T15:23:13.844589+00:00 0:00:00.464778 359026 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-25T15:23:10.676321+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-25T14:00:00+00:00 EmrJobFlowSensor 2023-03-25T15:11:09.594755+00:00 2023-03-25T15:21:11.315201+00:00 0:10:01.720446 359021 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-25T15:11:07.359130+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-25T14:00:00+00:00 EmrCreateJobFlowOperator 2023-03-25T15:10:47.733759+00:00 2023-03-25T15:10:48.558401+00:00 0:00:00.824642 359018 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-25T15:10:45.342254+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-25T14:00:00+00:00 PythonOperator 2023-03-25T15:10:27.536014+00:00 2023-03-25T15:10:31.975386+00:00 0:00:04.439372 359015 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-25T15:10:25.316367+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-25T13:00:00+00:00 TriggerDagRunOperator 2023-03-25T14:46:37.074740+00:00 2023-03-25T14:46:37.655023+00:00 0:00:00.580283 359008 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-25T14:46:34.436191+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-25T13:00:00+00:00 TriggerDagRunOperator 2023-03-25T14:46:36.962356+00:00 2023-03-25T14:46:37.542873+00:00 0:00:00.580517 359007 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-25T14:46:34.436221+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-25T13:00:00+00:00 EmrJobFlowSensor 2023-03-25T14:14:19.841699+00:00 2023-03-25T14:24:21.652239+00:00 0:10:01.810540 359004 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-25T14:14:16.562416+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-25T13:00:00+00:00 EmrCreateJobFlowOperator 2023-03-25T14:13:56.873402+00:00 2023-03-25T14:13:57.706211+00:00 0:00:00.832809 359001 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-25T14:13:54.552839+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-25T13:00:00+00:00 PythonOperator 2023-03-25T14:13:38.074779+00:00 2023-03-25T14:13:41.139169+00:00 0:00:03.064390 358998 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-25T14:13:34.535696+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-25T12:00:00+00:00 TriggerDagRunOperator 2023-03-25T13:25:35.411713+00:00 2023-03-25T13:25:36.004253+00:00 0:00:00.592540 358989 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-25T13:25:32.343629+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-25T12:00:00+00:00 TriggerDagRunOperator 2023-03-25T13:25:35.371587+00:00 2023-03-25T13:25:35.903615+00:00 0:00:00.532028 358988 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-25T13:25:32.343569+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-25T12:00:00+00:00 EmrJobFlowSensor 2023-03-25T13:07:41.435728+00:00 2023-03-25T13:17:43.078701+00:00 0:10:01.642973 358983 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-25T13:07:38.883030+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-25T12:00:00+00:00 EmrCreateJobFlowOperator 2023-03-25T13:07:17.406187+00:00 2023-03-25T13:07:18.246558+00:00 0:00:00.840371 358978 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-25T13:07:14.897844+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-25T11:00:00+00:00 TriggerDagRunOperator 2023-03-25T13:07:00.575370+00:00 2023-03-25T13:07:01.302419+00:00 0:00:00.727049 358974 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-25T13:06:54.577736+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-25T12:00:00+00:00 PythonOperator 2023-03-25T13:06:59.563154+00:00 2023-03-25T13:07:04.331920+00:00 0:00:04.768766 358973 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-25T13:06:54.577750+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-25T11:00:00+00:00 TriggerDagRunOperator 2023-03-25T13:06:59.370973+00:00 2023-03-25T13:06:59.922683+00:00 0:00:00.551710 358972 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-25T13:06:54.577702+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-25T11:00:00+00:00 EmrJobFlowSensor 2023-03-25T12:07:07.038134+00:00 2023-03-25T12:17:08.947231+00:00 0:10:01.909097 358967 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-25T12:07:04.575112+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-25T11:00:00+00:00 EmrCreateJobFlowOperator 2023-03-25T12:06:44.769157+00:00 2023-03-25T12:06:45.769078+00:00 0:00:00.999921 358964 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-25T12:06:42.555357+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-25T11:00:00+00:00 PythonOperator 2023-03-25T12:06:25.404252+00:00 2023-03-25T12:06:29.057797+00:00 0:00:03.653545 358961 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-25T12:06:22.537964+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-25T10:00:00+00:00 TriggerDagRunOperator 2023-03-25T11:20:32.339802+00:00 2023-03-25T11:20:32.849359+00:00 0:00:00.509557 358954 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-25T11:20:29.545723+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-25T10:00:00+00:00 TriggerDagRunOperator 2023-03-25T11:20:32.323536+00:00 2023-03-25T11:20:32.778192+00:00 0:00:00.454656 358953 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-25T11:20:29.545750+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-25T10:00:00+00:00 EmrJobFlowSensor 2023-03-25T11:09:02.514075+00:00 2023-03-25T11:19:04.358932+00:00 0:10:01.844857 358950 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-25T11:09:00.131308+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-25T10:00:00+00:00 EmrCreateJobFlowOperator 2023-03-25T11:08:40.345861+00:00 2023-03-25T11:08:41.237892+00:00 0:00:00.892031 358947 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-25T11:08:38.131845+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-25T10:00:00+00:00 PythonOperator 2023-03-25T11:08:23.469256+00:00 2023-03-25T11:08:26.538137+00:00 0:00:03.068881 358944 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-25T11:08:18.086089+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-25T09:00:00+00:00 TriggerDagRunOperator 2023-03-25T10:11:03.240852+00:00 2023-03-25T10:11:03.756854+00:00 0:00:00.516002 358933 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-25T10:11:00.405420+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-25T09:00:00+00:00 TriggerDagRunOperator 2023-03-25T10:11:03.153244+00:00 2023-03-25T10:11:03.649011+00:00 0:00:00.495767 358932 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-25T10:11:00.405372+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-25T09:00:00+00:00 EmrJobFlowSensor 2023-03-25T10:00:54.589590+00:00 2023-03-25T10:10:56.796214+00:00 0:10:02.206624 358926 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-25T10:00:52.090452+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-25T09:00:00+00:00 EmrCreateJobFlowOperator 2023-03-25T10:00:32.845165+00:00 2023-03-25T10:00:33.659257+00:00 0:00:00.814092 358924 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-25T10:00:30.114314+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-25T09:00:00+00:00 PythonOperator 2023-03-25T10:00:11.384876+00:00 2023-03-25T10:00:15.154075+00:00 0:00:03.769199 358922 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-25T10:00:08.018511+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-25T08:00:00+00:00 TriggerDagRunOperator 2023-03-25T09:32:09.315883+00:00 2023-03-25T09:32:09.821758+00:00 0:00:00.505875 358913 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-25T09:32:06.427199+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-25T08:00:00+00:00 TriggerDagRunOperator 2023-03-25T09:32:09.301676+00:00 2023-03-25T09:32:09.815853+00:00 0:00:00.514177 358912 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-25T09:32:06.427169+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-25T08:00:00+00:00 EmrJobFlowSensor 2023-03-25T09:21:48.533694+00:00 2023-03-25T09:31:50.423544+00:00 0:10:01.889850 358909 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-25T09:21:46.387309+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-25T08:00:00+00:00 EmrCreateJobFlowOperator 2023-03-25T09:21:28.513396+00:00 2023-03-25T09:21:29.380481+00:00 0:00:00.867085 358906 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-25T09:21:26.369531+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-25T08:00:00+00:00 PythonOperator 2023-03-25T09:21:06.530995+00:00 2023-03-25T09:21:10.545554+00:00 0:00:04.014559 358903 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-25T09:21:04.347984+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-25T07:00:00+00:00 TriggerDagRunOperator 2023-03-25T08:22:56.396964+00:00 2023-03-25T08:22:56.923189+00:00 0:00:00.526225 358893 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-25T08:22:53.708796+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-25T07:00:00+00:00 TriggerDagRunOperator 2023-03-25T08:22:56.334219+00:00 2023-03-25T08:22:56.790443+00:00 0:00:00.456224 358892 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-25T08:22:53.708767+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-25T07:00:00+00:00 EmrJobFlowSensor 2023-03-25T08:00:52.599824+00:00 2023-03-25T08:10:54.505467+00:00 0:10:01.905643 358885 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-25T08:00:50.120546+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-25T07:00:00+00:00 EmrCreateJobFlowOperator 2023-03-25T08:00:30.365289+00:00 2023-03-25T08:00:31.321314+00:00 0:00:00.956025 358883 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-25T08:00:28.097379+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-25T07:00:00+00:00 PythonOperator 2023-03-25T08:00:08.731775+00:00 2023-03-25T08:00:11.917114+00:00 0:00:03.185339 358880 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-25T08:00:06.084891+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-25T06:00:00+00:00 TriggerDagRunOperator 2023-03-25T07:14:26.392926+00:00 2023-03-25T07:14:26.896129+00:00 0:00:00.503203 358872 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-25T07:14:23.426888+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-25T06:00:00+00:00 TriggerDagRunOperator 2023-03-25T07:14:26.265123+00:00 2023-03-25T07:14:26.743229+00:00 0:00:00.478106 358871 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-25T07:14:23.426859+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-25T06:00:00+00:00 EmrJobFlowSensor 2023-03-25T07:01:14.848147+00:00 2023-03-25T07:11:16.718230+00:00 0:10:01.870083 358864 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-25T07:01:12.605194+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-25T06:00:00+00:00 EmrCreateJobFlowOperator 2023-03-25T07:00:52.769544+00:00 2023-03-25T07:00:53.905969+00:00 0:00:01.136425 358862 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-25T07:00:50.573852+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-25T06:00:00+00:00 PythonOperator 2023-03-25T07:00:31.340388+00:00 2023-03-25T07:00:36.689434+00:00 0:00:05.349046 358860 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-25T07:00:28.548288+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-25T05:00:00+00:00 TriggerDagRunOperator 2023-03-25T06:16:50.673486+00:00 2023-03-25T06:16:51.288705+00:00 0:00:00.615219 358851 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-25T06:16:47.810645+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-25T05:00:00+00:00 TriggerDagRunOperator 2023-03-25T06:16:50.517204+00:00 2023-03-25T06:16:51.099550+00:00 0:00:00.582346 358850 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-25T06:16:47.810616+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-25T05:00:00+00:00 EmrJobFlowSensor 2023-03-25T06:04:30.279368+00:00 2023-03-25T06:14:32.018245+00:00 0:10:01.738877 358843 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-25T06:04:28.115346+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-25T05:00:00+00:00 EmrCreateJobFlowOperator 2023-03-25T06:04:10.507016+00:00 2023-03-25T06:04:11.741822+00:00 0:00:01.234806 358841 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-25T06:04:08.091487+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-25T05:00:00+00:00 PythonOperator 2023-03-25T06:03:48.964553+00:00 2023-03-25T06:03:53.788311+00:00 0:00:04.823758 358839 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-25T06:03:46.071517+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-25T04:00:00+00:00 TriggerDagRunOperator 2023-03-25T05:22:30.346552+00:00 2023-03-25T05:22:30.806543+00:00 0:00:00.459991 358831 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-25T05:22:27.755089+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-25T04:00:00+00:00 TriggerDagRunOperator 2023-03-25T05:22:30.217454+00:00 2023-03-25T05:22:30.674164+00:00 0:00:00.456710 358830 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-25T05:22:27.755061+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-25T04:00:00+00:00 EmrJobFlowSensor 2023-03-25T05:03:23.581539+00:00 2023-03-25T05:13:25.253036+00:00 0:10:01.671497 358825 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-25T05:03:21.410705+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-25T04:00:00+00:00 EmrCreateJobFlowOperator 2023-03-25T05:03:04.045471+00:00 2023-03-25T05:03:04.857110+00:00 0:00:00.811639 358823 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-25T05:03:01.390817+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-25T04:00:00+00:00 PythonOperator 2023-03-25T05:00:15.420439+00:00 2023-03-25T05:00:19.384038+00:00 0:00:03.963599 358819 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-25T05:00:13.197364+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-25T03:00:00+00:00 TriggerDagRunOperator 2023-03-25T04:17:38.420078+00:00 2023-03-25T04:17:38.911408+00:00 0:00:00.491330 358810 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-25T04:17:35.971674+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-25T03:00:00+00:00 TriggerDagRunOperator 2023-03-25T04:17:38.313609+00:00 2023-03-25T04:17:38.764024+00:00 0:00:00.450415 358809 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-25T04:17:35.971702+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-25T03:00:00+00:00 EmrJobFlowSensor 2023-03-25T04:07:21.167086+00:00 2023-03-25T04:17:22.946634+00:00 0:10:01.779548 358806 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-25T04:07:18.926613+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-25T03:00:00+00:00 EmrCreateJobFlowOperator 2023-03-25T04:06:59.574882+00:00 2023-03-25T04:07:00.357897+00:00 0:00:00.783015 358803 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-25T04:06:56.862302+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-25T03:00:00+00:00 PythonOperator 2023-03-25T04:06:37.106443+00:00 2023-03-25T04:06:41.248536+00:00 0:00:04.142093 358800 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-25T04:06:34.843455+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-25T02:00:00+00:00 TriggerDagRunOperator 2023-03-25T03:24:38.182512+00:00 2023-03-25T03:24:38.679205+00:00 0:00:00.496693 358787 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-25T03:24:35.364715+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-25T02:00:00+00:00 TriggerDagRunOperator 2023-03-25T03:24:38.073441+00:00 2023-03-25T03:24:38.536066+00:00 0:00:00.462625 358786 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-25T03:24:35.364754+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-25T02:00:00+00:00 EmrJobFlowSensor 2023-03-25T03:00:53.745702+00:00 2023-03-25T03:10:55.482261+00:00 0:10:01.736559 358782 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-25T03:00:51.554320+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-25T02:00:00+00:00 EmrCreateJobFlowOperator 2023-03-25T03:00:33.695947+00:00 2023-03-25T03:00:34.537276+00:00 0:00:00.841329 358780 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-25T03:00:31.533547+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-25T02:00:00+00:00 PythonOperator 2023-03-25T03:00:12.031063+00:00 2023-03-25T03:00:15.261575+00:00 0:00:03.230512 358778 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-25T03:00:09.512854+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-25T01:00:00+00:00 TriggerDagRunOperator 2023-03-25T02:25:59.111185+00:00 2023-03-25T02:25:59.595632+00:00 0:00:00.484447 358771 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-25T02:25:56.764222+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-25T01:00:00+00:00 TriggerDagRunOperator 2023-03-25T02:25:59.137088+00:00 2023-03-25T02:25:59.609015+00:00 0:00:00.471927 358770 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-25T02:25:56.764194+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-25T01:00:00+00:00 EmrJobFlowSensor 2023-03-25T02:13:47.709013+00:00 2023-03-25T02:23:49.566628+00:00 0:10:01.857615 358765 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-25T02:13:45.346136+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-25T01:00:00+00:00 EmrCreateJobFlowOperator 2023-03-25T02:13:25.605463+00:00 2023-03-25T02:13:26.629986+00:00 0:00:01.024523 358762 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-25T02:13:23.325242+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-25T01:00:00+00:00 PythonOperator 2023-03-25T02:13:06.117133+00:00 2023-03-25T02:13:09.487259+00:00 0:00:03.370126 358759 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-25T02:13:03.357814+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-25T00:00:00+00:00 TriggerDagRunOperator 2023-03-25T01:12:57.801933+00:00 2023-03-25T01:12:58.291140+00:00 0:00:00.489207 358746 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-25T01:12:54.999251+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-25T00:00:00+00:00 TriggerDagRunOperator 2023-03-25T01:12:57.609221+00:00 2023-03-25T01:12:58.089007+00:00 0:00:00.479786 358745 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-25T01:12:54.999222+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-25T00:00:00+00:00 EmrJobFlowSensor 2023-03-25T01:02:36.633224+00:00 2023-03-25T01:12:38.377133+00:00 0:10:01.743909 358738 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-25T01:02:34.464618+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-25T00:00:00+00:00 EmrCreateJobFlowOperator 2023-03-25T01:02:16.664538+00:00 2023-03-25T01:02:17.474305+00:00 0:00:00.809767 358736 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-25T01:02:14.446519+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-25T00:00:00+00:00 PythonOperator 2023-03-25T01:01:55.756172+00:00 2023-03-25T01:01:59.393358+00:00 0:00:03.637186 358734 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-25T01:01:52.429865+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-24T23:00:00+00:00 TriggerDagRunOperator 2023-03-25T00:45:35.229565+00:00 2023-03-25T00:45:35.759229+00:00 0:00:00.529664 358728 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-25T00:45:32.654684+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-24T23:00:00+00:00 TriggerDagRunOperator 2023-03-25T00:45:35.041659+00:00 2023-03-25T00:45:35.534727+00:00 0:00:00.493068 358727 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-25T00:45:32.654725+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-24T23:00:00+00:00 EmrJobFlowSensor 2023-03-25T00:35:21.512633+00:00 2023-03-25T00:45:23.466887+00:00 0:10:01.954254 358723 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-25T00:35:18.419234+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-24T23:00:00+00:00 EmrCreateJobFlowOperator 2023-03-25T00:34:58.686000+00:00 2023-03-25T00:34:59.575977+00:00 0:00:00.889977 358720 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-25T00:34:56.347996+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-24T23:00:00+00:00 PythonOperator 2023-03-25T00:34:36.752407+00:00 2023-03-25T00:34:41.318408+00:00 0:00:04.566001 358717 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-25T00:34:34.325892+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-24T22:00:00+00:00 TriggerDagRunOperator 2023-03-24T23:11:08.904424+00:00 2023-03-24T23:11:09.427424+00:00 0:00:00.523000 358707 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-24T23:11:06.279571+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-24T22:00:00+00:00 TriggerDagRunOperator 2023-03-24T23:11:08.707859+00:00 2023-03-24T23:11:09.190587+00:00 0:00:00.482728 358706 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-24T23:11:06.279542+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-24T22:00:00+00:00 EmrJobFlowSensor 2023-03-24T23:00:46.684563+00:00 2023-03-24T23:10:48.497181+00:00 0:10:01.812618 358697 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-24T23:00:44.498555+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-24T22:00:00+00:00 EmrCreateJobFlowOperator 2023-03-24T23:00:27.207775+00:00 2023-03-24T23:00:28.029971+00:00 0:00:00.822196 358694 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-24T23:00:24.474590+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-24T22:00:00+00:00 PythonOperator 2023-03-24T23:00:04.966392+00:00 2023-03-24T23:00:08.493089+00:00 0:00:03.526697 358691 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-24T23:00:02.461961+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-24T21:00:00+00:00 TriggerDagRunOperator 2023-03-24T22:11:26.209115+00:00 2023-03-24T22:11:26.695341+00:00 0:00:00.486226 358681 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-24T22:11:23.680871+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-24T21:00:00+00:00 TriggerDagRunOperator 2023-03-24T22:11:26.126012+00:00 2023-03-24T22:11:26.582836+00:00 0:00:00.456824 358680 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-24T22:11:23.680844+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-24T21:00:00+00:00 EmrJobFlowSensor 2023-03-24T22:00:58.842037+00:00 2023-03-24T22:11:00.634152+00:00 0:10:01.792115 358673 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-24T22:00:56.326878+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-24T21:00:00+00:00 EmrCreateJobFlowOperator 2023-03-24T22:00:38.607187+00:00 2023-03-24T22:00:39.475852+00:00 0:00:00.868665 358672 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-24T22:00:36.249527+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-24T21:00:00+00:00 PythonOperator 2023-03-24T22:00:16.945271+00:00 2023-03-24T22:00:20.939376+00:00 0:00:03.994105 358669 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-24T22:00:13.923543+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-24T20:00:00+00:00 TriggerDagRunOperator 2023-03-24T21:20:55.497040+00:00 2023-03-24T21:20:56.276059+00:00 0:00:00.779019 358660 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-24T21:20:52.983359+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-24T20:00:00+00:00 TriggerDagRunOperator 2023-03-24T21:20:55.465416+00:00 2023-03-24T21:20:56.235631+00:00 0:00:00.770215 358659 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-24T21:20:52.983388+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-24T20:00:00+00:00 EmrJobFlowSensor 2023-03-24T21:01:47.361552+00:00 2023-03-24T21:11:49.253778+00:00 0:10:01.892226 358653 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-24T21:01:45.168667+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-24T20:00:00+00:00 EmrCreateJobFlowOperator 2023-03-24T21:01:25.144069+00:00 2023-03-24T21:01:26.073158+00:00 0:00:00.929089 358651 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-24T21:01:23.012501+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-24T20:00:00+00:00 PythonOperator 2023-03-24T21:00:21.658726+00:00 2023-03-24T21:00:25.086056+00:00 0:00:03.427330 358648 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-24T21:00:18.690180+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-24T19:00:00+00:00 TriggerDagRunOperator 2023-03-24T20:11:25.223620+00:00 2023-03-24T20:11:25.931062+00:00 0:00:00.707442 358640 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-24T20:11:22.396995+00:00 2 default_pool