Task Instances

  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 2021-07-05T00:00:00+00:00 TriggerDagRunOperator 2021-07-05T01:09:13.041690+00:00 2021-07-05T01:09:13.423428+00:00 0:00:00.381738 49915 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T01:09:10.761025+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-05T00:05:00+00:00 EmrJobFlowSensor 2021-07-05T01:05:49.050584+00:00 2021-07-05T01:13:51.611000+00:00 0:08:02.560416 49914 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T01:05:46.305060+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-05T00:05:00+00:00 EmrCreateJobFlowOperator 2021-07-05T01:05:26.506783+00:00 2021-07-05T01:05:28.200866+00:00 0:00:01.694083 49913 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-05T01:05:24.284140+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-05T00:05:00+00:00 PythonOperator 2021-07-05T01:05:06.495011+00:00 2021-07-05T01:05:09.806600+00:00 0:00:03.311589 49912 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T01:05:04.212348+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-05T00:00:00+00:00 EmrJobFlowSensor 2021-07-05T01:00:50.079083+00:00 2021-07-05T01:08:52.736087+00:00 0:08:02.657004 49910 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T01:00:47.743384+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-05T00:00:00+00:00 EmrCreateJobFlowOperator 2021-07-05T01:00:30.045013+00:00 2021-07-05T01:00:31.783742+00:00 0:00:01.738729 49908 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-05T01:00:27.773130+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-05T00:00:00+00:00 PythonOperator 2021-07-05T01:00:08.390571+00:00 2021-07-05T01:00:11.764939+00:00 0:00:03.374368 49906 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-05T01:00:05.769619+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-04T23:00:00+00:00 EmrJobFlowSensor 2021-07-05T00:12:43.427795+00:00 2021-07-05T00:22:46.134639+00:00 0:10:02.706844 49904 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T00:12:40.895664+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-04T23:00:00+00:00 EmrJobFlowSensor 2021-07-05T00:12:41.082278+00:00 2021-07-05T00:21:44.072778+00:00 0:09:02.990500 49903 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T00:12:38.894971+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-04T23:00:00+00:00 EmrCreateJobFlowOperator 2021-07-05T00:12:21.219044+00:00 2021-07-05T00:12:23.065879+00:00 0:00:01.846835 49902 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-05T00:12:18.799098+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-04T23:00:00+00:00 EmrCreateJobFlowOperator 2021-07-05T00:12:19.368793+00:00 2021-07-05T00:12:21.118952+00:00 0:00:01.750159 49901 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-05T00:12:16.855885+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-04T23:00:00+00:00 PythonOperator 2021-07-05T00:12:00.049136+00:00 2021-07-05T00:12:03.628206+00:00 0:00:03.579070 49900 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T00:11:56.568771+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-04T23:00:00+00:00 PythonOperator 2021-07-05T00:11:59.811663+00:00 2021-07-05T00:12:03.536773+00:00 0:00:03.725110 49899 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T00:11:56.568815+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-04T23:00:00+00:00 TriggerDagRunOperator 2021-07-05T00:11:51.045960+00:00 2021-07-05T00:11:51.591849+00:00 0:00:00.545889 49898 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T00:11:48.547815+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-04T23:00:00+00:00 TriggerDagRunOperator 2021-07-05T00:11:50.993233+00:00 2021-07-05T00:11:51.423799+00:00 0:00:00.430566 49897 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T00:11:48.547867+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-04T23:05:00+00:00 EmrJobFlowSensor 2021-07-05T00:06:06.495900+00:00 2021-07-05T00:14:08.940408+00:00 0:08:02.444508 49896 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T00:06:04.174413+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-04T23:05:00+00:00 EmrCreateJobFlowOperator 2021-07-05T00:05:44.467930+00:00 2021-07-05T00:05:46.100598+00:00 0:00:01.632668 49895 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-05T00:05:42.163375+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-04T23:05:00+00:00 PythonOperator 2021-07-05T00:05:24.241490+00:00 2021-07-05T00:05:27.843423+00:00 0:00:03.601933 49894 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T00:05:22.023512+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-07-04T23:00:00+00:00 EmrJobFlowSensor 2021-07-05T00:01:07.897677+00:00 2021-07-05T00:11:11.084299+00:00 0:10:03.186622 49893 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T00:01:05.647309+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-04T23:00:00+00:00 EmrJobFlowSensor 2021-07-05T00:00:53.935281+00:00 2021-07-05T00:10:57.120588+00:00 0:10:03.185307 49892 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T00:00:51.634109+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-07-04T23:00:00+00:00 EmrCreateJobFlowOperator 2021-07-05T00:00:43.925586+00:00 2021-07-05T00:00:45.600695+00:00 0:00:01.675109 49891 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-05T00:00:41.699509+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-04T23:00:00+00:00 EmrCreateJobFlowOperator 2021-07-05T00:00:32.520626+00:00 2021-07-05T00:00:34.515630+00:00 0:00:01.995004 49890 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-05T00:00:29.763322+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-07-04T23:00:00+00:00 PythonOperator 2021-07-05T00:00:21.968091+00:00 2021-07-05T00:00:25.407126+00:00 0:00:03.439035 49889 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T00:00:19.600410+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-04T23:00:00+00:00 PythonOperator 2021-07-05T00:00:09.995828+00:00 2021-07-05T00:00:13.680874+00:00 0:00:03.685046 49888 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-05T00:00:07.594412+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-04T22:00:00+00:00 EmrJobFlowSensor 2021-07-04T23:22:54.148750+00:00 2021-07-04T23:22:55.773000+00:00 0:00:01.624250 49886 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T23:22:51.780247+00:00 3 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-04T22:00:00+00:00 EmrJobFlowSensor 2021-07-04T23:11:15.134682+00:00 2021-07-04T23:20:17.916142+00:00 0:09:02.781460 49884 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T23:11:12.577642+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-04T22:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T23:10:57.628257+00:00 2021-07-04T23:10:59.348700+00:00 0:00:01.720443 49883 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T23:10:54.580357+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-04T22:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T23:10:54.990442+00:00 2021-07-04T23:10:57.164788+00:00 0:00:02.174346 49882 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T23:10:52.569674+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-04T22:00:00+00:00 PythonOperator 2021-07-04T23:10:32.228529+00:00 2021-07-04T23:10:35.865085+00:00 0:00:03.636556 49881 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T23:10:28.554535+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-04T22:00:00+00:00 PythonOperator 2021-07-04T23:10:26.682327+00:00 2021-07-04T23:10:32.089669+00:00 0:00:05.407342 49880 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T23:10:24.439368+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-04T22:00:00+00:00 TriggerDagRunOperator 2021-07-04T23:10:06.638352+00:00 2021-07-04T23:10:07.185534+00:00 0:00:00.547182 49879 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T23:10:04.417611+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-04T22:00:00+00:00 TriggerDagRunOperator 2021-07-04T23:10:06.576597+00:00 2021-07-04T23:10:06.986380+00:00 0:00:00.409783 49878 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T23:10:04.417643+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-04T22:05:00+00:00 EmrJobFlowSensor 2021-07-04T23:05:56.151426+00:00 2021-07-04T23:14:58.720332+00:00 0:09:02.568906 49877 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T23:05:54.008015+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-04T22:05:00+00:00 EmrCreateJobFlowOperator 2021-07-04T23:05:34.230350+00:00 2021-07-04T23:05:35.963244+00:00 0:00:01.732894 49876 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T23:05:31.986846+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-04T22:05:00+00:00 PythonOperator 2021-07-04T23:05:12.275863+00:00 2021-07-04T23:05:15.954883+00:00 0:00:03.679020 49875 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T23:05:09.957437+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-04T22:00:00+00:00 EmrJobFlowSensor 2021-07-04T23:01:00.270171+00:00 2021-07-04T23:10:02.947871+00:00 0:09:02.677700 49874 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T23:00:57.577431+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-07-03T23:00:00+00:00 EmrJobFlowSensor 2021-07-04T23:00:48.058845+00:00 2021-07-04T23:10:50.842046+00:00 0:10:02.783201 49873 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T23:00:45.413152+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-07-04T22:00:00+00:00 EmrJobFlowSensor 2021-07-04T23:00:47.687689+00:00 2021-07-04T23:10:50.697042+00:00 0:10:03.009353 49872 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T23:00:45.413120+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-04T22:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T23:00:39.692761+00:00 2021-07-04T23:00:41.437894+00:00 0:00:01.745133 49871 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-04T23:00:37.408370+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-07-03T23:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T23:00:26.289773+00:00 2021-07-04T23:00:28.091836+00:00 0:00:01.802063 49870 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T23:00:23.464238+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-07-04T22:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T23:00:25.995678+00:00 2021-07-04T23:00:27.722880+00:00 0:00:01.727202 49869 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T23:00:23.464203+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-04T22:00:00+00:00 PythonOperator 2021-07-04T23:00:17.781145+00:00 2021-07-04T23:00:21.237200+00:00 0:00:03.456055 49868 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-04T23:00:15.447085+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-07-04T22:00:00+00:00 PythonOperator 2021-07-04T23:00:06.559265+00:00 2021-07-04T23:00:10.062635+00:00 0:00:03.503370 49867 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T23:00:03.342066+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-07-03T23:00:00+00:00 PythonOperator 2021-07-04T23:00:04.741051+00:00 2021-07-04T23:00:08.526452+00:00 0:00:03.785401 49866 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T23:00:01.453838+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-04T21:00:00+00:00 EmrJobFlowSensor 2021-07-04T22:11:19.680504+00:00 2021-07-04T22:21:22.501889+00:00 0:10:02.821385 49864 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T22:11:17.514894+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-04T21:00:00+00:00 EmrJobFlowSensor 2021-07-04T22:11:15.910303+00:00 2021-07-04T22:21:19.084833+00:00 0:10:03.174530 49863 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T22:11:13.486038+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-04T21:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T22:10:59.892218+00:00 2021-07-04T22:11:01.654496+00:00 0:00:01.762278 49862 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T22:10:57.435428+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-04T21:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T22:10:53.941869+00:00 2021-07-04T22:10:55.722165+00:00 0:00:01.780296 49861 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T22:10:51.421689+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-04T21:00:00+00:00 PythonOperator 2021-07-04T22:10:37.990043+00:00 2021-07-04T22:10:41.770760+00:00 0:00:03.780717 49860 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T22:10:35.407323+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-04T21:00:00+00:00 PythonOperator 2021-07-04T22:10:32.006452+00:00 2021-07-04T22:10:35.649513+00:00 0:00:03.643061 49859 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T22:10:29.472929+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-04T21:00:00+00:00 TriggerDagRunOperator 2021-07-04T22:10:18.295117+00:00 2021-07-04T22:10:18.873024+00:00 0:00:00.577907 49858 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T22:10:15.471166+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-04T21:00:00+00:00 TriggerDagRunOperator 2021-07-04T22:10:17.901197+00:00 2021-07-04T22:10:18.291126+00:00 0:00:00.389929 49857 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T22:10:15.471117+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-04T21:05:00+00:00 EmrJobFlowSensor 2021-07-04T22:05:49.173764+00:00 2021-07-04T22:13:51.746665+00:00 0:08:02.572901 49856 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T22:05:46.853992+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-04T21:05:00+00:00 EmrCreateJobFlowOperator 2021-07-04T22:05:28.884621+00:00 2021-07-04T22:05:30.537561+00:00 0:00:01.652940 49855 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T22:05:26.754913+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-04T21:05:00+00:00 PythonOperator 2021-07-04T22:05:06.863582+00:00 2021-07-04T22:05:10.544103+00:00 0:00:03.680521 49854 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T22:05:04.734532+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-07-04T21:00:00+00:00 EmrJobFlowSensor 2021-07-04T22:01:20.478988+00:00 2021-07-04T22:11:23.414826+00:00 0:10:02.935838 49853 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T22:01:18.258918+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-04T21:00:00+00:00 EmrJobFlowSensor 2021-07-04T22:01:06.513739+00:00 2021-07-04T22:10:09.401527+00:00 0:09:02.887788 49852 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T22:01:04.250066+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-07-04T21:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T22:01:00.704337+00:00 2021-07-04T22:01:02.511365+00:00 0:00:01.807028 49851 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T22:00:58.261733+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-04T21:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T22:00:44.763846+00:00 2021-07-04T22:00:46.643540+00:00 0:00:01.879694 49850 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-04T22:00:42.252378+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-07-04T21:00:00+00:00 PythonOperator 2021-07-04T22:00:38.511385+00:00 2021-07-04T22:00:42.426836+00:00 0:00:03.915451 49849 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T22:00:36.166282+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-04T21:00:00+00:00 PythonOperator 2021-07-04T22:00:18.343566+00:00 2021-07-04T22:00:22.057925+00:00 0:00:03.714359 49848 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-04T22:00:16.099260+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-04T20:05:00+00:00 EmrJobFlowSensor 2021-07-04T21:13:12.349238+00:00 2021-07-04T21:14:14.090418+00:00 0:01:01.741180 49846 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T21:13:10.111915+00:00 3 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-04T20:00:00+00:00 EmrJobFlowSensor 2021-07-04T21:12:00.519553+00:00 2021-07-04T21:23:03.707815+00:00 0:11:03.188262 49845 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T21:11:58.044060+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-04T20:00:00+00:00 EmrJobFlowSensor 2021-07-04T21:11:58.159715+00:00 2021-07-04T21:21:01.412772+00:00 0:09:03.253057 49844 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T21:11:56.007991+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-04T20:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T21:11:38.746536+00:00 2021-07-04T21:11:40.459143+00:00 0:00:01.712607 49843 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T21:11:35.994155+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-04T20:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T21:11:36.636349+00:00 2021-07-04T21:11:38.672698+00:00 0:00:02.036349 49842 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T21:11:34.065275+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-04T20:00:00+00:00 PythonOperator 2021-07-04T21:11:16.567378+00:00 2021-07-04T21:11:20.580716+00:00 0:00:04.013338 49841 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T21:11:13.899941+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-04T20:00:00+00:00 PythonOperator 2021-07-04T21:11:14.390404+00:00 2021-07-04T21:11:18.435877+00:00 0:00:04.045473 49840 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T21:11:11.961924+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-04T20:00:00+00:00 TriggerDagRunOperator 2021-07-04T21:11:00.681399+00:00 2021-07-04T21:11:01.179126+00:00 0:00:00.497727 49839 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T21:10:58.047943+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-04T20:00:00+00:00 TriggerDagRunOperator 2021-07-04T21:11:00.527175+00:00 2021-07-04T21:11:00.928098+00:00 0:00:00.400923 49838 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T21:10:58.047995+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-04T20:05:00+00:00 EmrCreateJobFlowOperator 2021-07-04T21:05:43.581935+00:00 2021-07-04T21:05:45.261027+00:00 0:00:01.679092 49836 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T21:05:41.386539+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-04T20:05:00+00:00 PythonOperator 2021-07-04T21:05:23.670032+00:00 2021-07-04T21:05:27.049242+00:00 0:00:03.379210 49835 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T21:05:21.317069+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-07-04T20:00:00+00:00 EmrJobFlowSensor 2021-07-04T21:01:07.121638+00:00 2021-07-04T21:12:10.112947+00:00 0:11:02.991309 49834 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T21:01:04.810118+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-04T20:00:00+00:00 EmrJobFlowSensor 2021-07-04T21:00:51.344977+00:00 2021-07-04T21:10:54.192220+00:00 0:10:02.847243 49833 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T21:00:48.793891+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-07-04T20:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T21:00:43.087335+00:00 2021-07-04T21:00:44.792092+00:00 0:00:01.704757 49832 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T21:00:40.853162+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-04T20:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T21:00:29.363612+00:00 2021-07-04T21:00:31.090316+00:00 0:00:01.726704 49831 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-04T21:00:26.764970+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-07-04T20:00:00+00:00 PythonOperator 2021-07-04T21:00:20.989135+00:00 2021-07-04T21:00:24.624740+00:00 0:00:03.635605 49830 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T21:00:18.789140+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-04T20:00:00+00:00 PythonOperator 2021-07-04T21:00:07.004211+00:00 2021-07-04T21:00:10.631479+00:00 0:00:03.627268 49829 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-04T21:00:04.746346+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-04T19:00:00+00:00 EmrJobFlowSensor 2021-07-04T20:11:42.532889+00:00 2021-07-04T20:21:45.620316+00:00 0:10:03.087427 49827 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T20:11:40.162823+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-04T19:00:00+00:00 EmrJobFlowSensor 2021-07-04T20:11:34.396662+00:00 2021-07-04T20:20:36.904416+00:00 0:09:02.507754 49826 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T20:11:32.089342+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-04T19:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T20:11:22.628936+00:00 2021-07-04T20:11:24.422319+00:00 0:00:01.793383 49825 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T20:11:20.258405+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-04T19:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T20:11:10.565564+00:00 2021-07-04T20:11:12.284342+00:00 0:00:01.718778 49824 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T20:11:08.043695+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-04T19:00:00+00:00 PythonOperator 2021-07-04T20:10:42.476237+00:00 2021-07-04T20:10:46.133132+00:00 0:00:03.656895 49823 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T20:10:40.003878+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-04T19:00:00+00:00 PythonOperator 2021-07-04T20:10:42.475830+00:00 2021-07-04T20:10:46.159474+00:00 0:00:03.683644 49822 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T20:10:40.003923+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-04T19:00:00+00:00 TriggerDagRunOperator 2021-07-04T20:10:32.840007+00:00 2021-07-04T20:10:33.258425+00:00 0:00:00.418418 49821 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T20:10:29.987453+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-04T19:00:00+00:00 TriggerDagRunOperator 2021-07-04T20:10:32.764067+00:00 2021-07-04T20:10:33.310174+00:00 0:00:00.546107 49820 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T20:10:29.987487+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-04T19:05:00+00:00 EmrJobFlowSensor 2021-07-04T20:06:11.979122+00:00 2021-07-04T20:15:14.906342+00:00 0:09:02.927220 49819 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T20:06:09.573176+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-04T19:05:00+00:00 EmrCreateJobFlowOperator 2021-07-04T20:05:49.879618+00:00 2021-07-04T20:05:51.570238+00:00 0:00:01.690620 49818 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T20:05:47.568261+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-04T19:05:00+00:00 PythonOperator 2021-07-04T20:05:19.675783+00:00 2021-07-04T20:05:23.368123+00:00 0:00:03.692340 49817 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T20:05:17.458818+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-07-04T19:00:00+00:00 EmrJobFlowSensor 2021-07-04T20:01:17.325896+00:00 2021-07-04T20:11:20.202246+00:00 0:10:02.876350 49816 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T20:01:15.093833+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-04T19:00:00+00:00 EmrJobFlowSensor 2021-07-04T20:01:17.219333+00:00 2021-07-04T20:10:20.191554+00:00 0:09:02.972221 49815 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T20:01:15.093806+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-04T19:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T20:00:55.782064+00:00 2021-07-04T20:00:57.567058+00:00 0:00:01.784994 49814 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-04T20:00:53.150270+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-07-04T19:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T20:00:55.722199+00:00 2021-07-04T20:00:57.585141+00:00 0:00:01.862942 49813 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T20:00:53.150313+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-04T19:00:00+00:00 PythonOperator 2021-07-04T20:00:33.752819+00:00 2021-07-04T20:00:37.563265+00:00 0:00:03.810446 49812 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-04T20:00:31.044065+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-07-04T19:00:00+00:00 PythonOperator 2021-07-04T20:00:33.778926+00:00 2021-07-04T20:00:37.251358+00:00 0:00:03.472432 49811 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T20:00:31.044094+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-04T18:00:00+00:00 EmrJobFlowSensor 2021-07-04T19:12:27.883740+00:00 2021-07-04T19:21:30.725685+00:00 0:09:02.841945 49809 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T19:12:25.493933+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-04T18:00:00+00:00 EmrJobFlowSensor 2021-07-04T19:12:07.720866+00:00 2021-07-04T19:21:10.592206+00:00 0:09:02.871340 49808 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T19:12:05.448193+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-04T18:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T19:11:47.666018+00:00 2021-07-04T19:11:49.349710+00:00 0:00:01.683692 49807 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T19:11:45.430326+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-04T18:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T19:11:43.665927+00:00 2021-07-04T19:11:45.378610+00:00 0:00:01.712683 49806 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T19:11:41.427956+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-04T18:00:00+00:00 PythonOperator 2021-07-04T19:11:27.188655+00:00 2021-07-04T19:11:31.099987+00:00 0:00:03.911332 49805 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T19:11:23.465955+00:00 2 default_pool