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-history-job_v002 check_cluster_status 2021-05-10T20:00:00+00:00 EmrJobFlowSensor 2021-05-10T21:11:00.343777+00:00 2021-05-10T21:19:03.068463+00:00 0:08:02.724686 26682 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T21:10:58.023642+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-10T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T21:10:50.431007+00:00 2021-05-10T21:10:52.148511+00:00 0:00:01.717504 26681 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T21:10:48.013849+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-10T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T21:10:38.392832+00:00 2021-05-10T21:10:40.060222+00:00 0:00:01.667390 26680 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T21:10:36.052869+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-10T20:00:00+00:00 PythonOperator 2021-05-10T21:10:28.474725+00:00 2021-05-10T21:10:31.791238+00:00 0:00:03.316513 26679 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T21:10:26.060560+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-10T20:00:00+00:00 PythonOperator 2021-05-10T21:10:16.734117+00:00 2021-05-10T21:10:19.947148+00:00 0:00:03.213031 26678 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T21:10:14.061311+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T20:00:00+00:00 TriggerDagRunOperator 2021-05-10T21:10:08.869518+00:00 2021-05-10T21:10:09.318670+00:00 0:00:00.449152 26677 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T21:10:05.855197+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T20:00:00+00:00 TriggerDagRunOperator 2021-05-10T21:10:08.819039+00:00 2021-05-10T21:10:09.382525+00:00 0:00:00.563486 26676 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T21:10:05.855158+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-10T20:05:00+00:00 EmrJobFlowSensor 2021-05-10T21:05:55.353387+00:00 2021-05-10T21:14:57.954520+00:00 0:09:02.601133 26674 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T21:05:52.973435+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-10T20:05:00+00:00 EmrCreateJobFlowOperator 2021-05-10T21:05:35.365477+00:00 2021-05-10T21:05:37.101413+00:00 0:00:01.735936 26673 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T21:05:32.975170+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-10T20:05:00+00:00 PythonOperator 2021-05-10T21:05:13.258611+00:00 2021-05-10T21:05:16.319600+00:00 0:00:03.060989 26672 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T21:05:10.892296+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T20:00:00+00:00 EmrJobFlowSensor 2021-05-10T21:00:58.971648+00:00 2021-05-10T21:10:01.671800+00:00 0:09:02.700152 26671 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T21:00:56.593695+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T21:00:36.977361+00:00 2021-05-10T21:00:38.801501+00:00 0:00:01.824140 26670 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T21:00:34.577946+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T20:00:00+00:00 PythonOperator 2021-05-10T21:00:15.068149+00:00 2021-05-10T21:00:18.194054+00:00 0:00:03.125905 26669 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T21:00:12.543999+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-10T19:00:00+00:00 EmrJobFlowSensor 2021-05-10T20:11:35.561354+00:00 2021-05-10T20:20:38.124810+00:00 0:09:02.563456 26668 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T20:11:33.479419+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-10T19:00:00+00:00 EmrJobFlowSensor 2021-05-10T20:11:21.605554+00:00 2021-05-10T20:20:24.174811+00:00 0:09:02.569257 26667 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T20:11:19.463476+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-10T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T20:11:13.801319+00:00 2021-05-10T20:11:15.677760+00:00 0:00:01.876441 26666 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T20:11:11.464885+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-10T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T20:10:59.571174+00:00 2021-05-10T20:11:01.261286+00:00 0:00:01.690112 26665 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T20:10:57.410014+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-10T19:00:00+00:00 PythonOperator 2021-05-10T20:10:51.820154+00:00 2021-05-10T20:10:55.089460+00:00 0:00:03.269306 26664 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T20:10:49.464103+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-10T19:00:00+00:00 PythonOperator 2021-05-10T20:10:37.510902+00:00 2021-05-10T20:10:40.652564+00:00 0:00:03.141662 26663 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T20:10:35.385537+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T19:00:00+00:00 TriggerDagRunOperator 2021-05-10T20:10:34.132349+00:00 2021-05-10T20:10:34.692267+00:00 0:00:00.559918 26662 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T20:10:31.444598+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T19:00:00+00:00 TriggerDagRunOperator 2021-05-10T20:10:33.869899+00:00 2021-05-10T20:10:34.322384+00:00 0:00:00.452485 26661 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T20:10:31.444551+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-10T19:05:00+00:00 EmrJobFlowSensor 2021-05-10T20:06:07.500609+00:00 2021-05-10T20:15:10.193176+00:00 0:09:02.692567 26659 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T20:06:05.233062+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-10T19:05:00+00:00 EmrCreateJobFlowOperator 2021-05-10T20:05:45.441753+00:00 2021-05-10T20:05:47.058109+00:00 0:00:01.616356 26658 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T20:05:43.211040+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-10T19:05:00+00:00 PythonOperator 2021-05-10T20:05:23.401586+00:00 2021-05-10T20:05:26.502272+00:00 0:00:03.100686 26657 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T20:05:21.188465+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T19:00:00+00:00 EmrJobFlowSensor 2021-05-10T20:01:06.958752+00:00 2021-05-10T20:10:09.887627+00:00 0:09:02.928875 26656 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T20:01:04.651609+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T20:00:46.651798+00:00 2021-05-10T20:00:48.362799+00:00 0:00:01.711001 26655 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T20:00:44.522996+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T19:00:00+00:00 PythonOperator 2021-05-10T20:00:24.737697+00:00 2021-05-10T20:00:27.916606+00:00 0:00:03.178909 26654 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T20:00:22.509029+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-10T18:00:00+00:00 EmrJobFlowSensor 2021-05-10T19:12:00.178880+00:00 2021-05-10T19:23:03.348190+00:00 0:11:03.169310 26653 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T19:11:57.707829+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-10T18:00:00+00:00 EmrJobFlowSensor 2021-05-10T19:11:40.142127+00:00 2021-05-10T19:20:42.809785+00:00 0:09:02.667658 26652 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T19:11:37.691809+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-10T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T19:11:37.832935+00:00 2021-05-10T19:11:39.802447+00:00 0:00:01.969512 26651 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T19:11:35.694178+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-10T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T19:11:18.157292+00:00 2021-05-10T19:11:19.886817+00:00 0:00:01.729525 26650 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T19:11:15.648913+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-10T18:00:00+00:00 PythonOperator 2021-05-10T19:11:15.999446+00:00 2021-05-10T19:11:19.569847+00:00 0:00:03.570401 26649 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T19:11:13.646990+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-10T18:00:00+00:00 PythonOperator 2021-05-10T19:10:58.031984+00:00 2021-05-10T19:11:01.065474+00:00 0:00:03.033490 26648 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T19:10:55.632384+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T18:00:00+00:00 TriggerDagRunOperator 2021-05-10T19:10:49.995963+00:00 2021-05-10T19:10:50.518960+00:00 0:00:00.522997 26647 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T19:10:47.626467+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T18:00:00+00:00 TriggerDagRunOperator 2021-05-10T19:10:49.765059+00:00 2021-05-10T19:10:50.182570+00:00 0:00:00.417511 26646 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T19:10:47.626435+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-10T18:05:00+00:00 EmrJobFlowSensor 2021-05-10T19:07:53.681112+00:00 2021-05-10T19:15:56.302340+00:00 0:08:02.621228 26645 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T19:07:51.433418+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-10T18:05:00+00:00 EmrCreateJobFlowOperator 2021-05-10T19:07:25.498854+00:00 2021-05-10T19:07:27.148293+00:00 0:00:01.649439 26644 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T19:07:23.408202+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-10T18:05:00+00:00 PythonOperator 2021-05-10T19:06:59.997035+00:00 2021-05-10T19:07:03.126042+00:00 0:00:03.129007 26643 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T19:06:57.387794+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T18:00:00+00:00 EmrJobFlowSensor 2021-05-10T19:01:17.601480+00:00 2021-05-10T19:10:20.426826+00:00 0:09:02.825346 26641 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T19:01:15.512621+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T19:00:47.832394+00:00 2021-05-10T19:00:49.522440+00:00 0:00:01.690046 26640 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T19:00:45.490881+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T18:00:00+00:00 PythonOperator 2021-05-10T19:00:19.676189+00:00 2021-05-10T19:00:22.793685+00:00 0:00:03.117496 26639 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T19:00:17.419939+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-10T17:00:00+00:00 EmrJobFlowSensor 2021-05-10T18:12:30.407501+00:00 2021-05-10T18:21:33.091312+00:00 0:09:02.683811 26638 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T18:12:28.105291+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-10T17:00:00+00:00 EmrJobFlowSensor 2021-05-10T18:12:18.346635+00:00 2021-05-10T18:22:21.207274+00:00 0:10:02.860639 26637 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T18:12:16.098695+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-10T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T18:12:10.410539+00:00 2021-05-10T18:12:12.219837+00:00 0:00:01.809298 26636 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T18:12:08.088590+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-10T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T18:11:56.651319+00:00 2021-05-10T18:11:58.370829+00:00 0:00:01.719510 26635 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T18:11:54.059273+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-10T17:00:00+00:00 PythonOperator 2021-05-10T18:11:48.095642+00:00 2021-05-10T18:11:51.179792+00:00 0:00:03.084150 26634 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T18:11:46.020461+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-10T17:00:00+00:00 PythonOperator 2021-05-10T18:11:34.262994+00:00 2021-05-10T18:11:37.715218+00:00 0:00:03.452224 26633 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T18:11:32.011287+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T17:00:00+00:00 TriggerDagRunOperator 2021-05-10T18:11:28.399694+00:00 2021-05-10T18:11:28.917600+00:00 0:00:00.517906 26632 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T18:11:26.004118+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T17:00:00+00:00 TriggerDagRunOperator 2021-05-10T18:11:28.228802+00:00 2021-05-10T18:11:28.632407+00:00 0:00:00.403605 26631 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T18:11:26.004087+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-10T17:05:00+00:00 EmrJobFlowSensor 2021-05-10T18:06:07.739412+00:00 2021-05-10T18:14:10.317046+00:00 0:08:02.577634 26630 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T18:06:05.562893+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-10T17:05:00+00:00 EmrCreateJobFlowOperator 2021-05-10T18:05:45.646598+00:00 2021-05-10T18:05:47.268370+00:00 0:00:01.621772 26629 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T18:05:43.484641+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-10T17:05:00+00:00 PythonOperator 2021-05-10T18:05:21.715979+00:00 2021-05-10T18:05:24.790632+00:00 0:00:03.074653 26628 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T18:05:19.459353+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T17:00:00+00:00 EmrJobFlowSensor 2021-05-10T18:01:07.677654+00:00 2021-05-10T18:11:10.635419+00:00 0:10:02.957765 26626 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T18:01:05.469377+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T18:00:41.630143+00:00 2021-05-10T18:00:43.436543+00:00 0:00:01.806400 26625 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T18:00:39.448509+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T17:00:00+00:00 PythonOperator 2021-05-10T18:00:19.803620+00:00 2021-05-10T18:00:23.019777+00:00 0:00:03.216157 26624 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T18:00:17.430238+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-10T16:00:00+00:00 EmrJobFlowSensor 2021-05-10T17:11:06.895156+00:00 2021-05-10T17:21:09.670262+00:00 0:10:02.775106 26623 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T17:11:04.645287+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-10T16:00:00+00:00 EmrJobFlowSensor 2021-05-10T17:11:05.123951+00:00 2021-05-10T17:21:08.027421+00:00 0:10:02.903470 26622 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T17:11:02.663818+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-10T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T17:10:45.215124+00:00 2021-05-10T17:10:47.032158+00:00 0:00:01.817034 26621 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T17:10:42.674075+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-10T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T17:10:42.782020+00:00 2021-05-10T17:10:44.496852+00:00 0:00:01.714832 26620 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T17:10:40.615311+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-10T16:00:00+00:00 PythonOperator 2021-05-10T17:10:25.149101+00:00 2021-05-10T17:10:28.259963+00:00 0:00:03.110862 26619 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T17:10:22.602114+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-10T16:00:00+00:00 PythonOperator 2021-05-10T17:10:22.931679+00:00 2021-05-10T17:10:26.552638+00:00 0:00:03.620959 26618 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T17:10:20.596690+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T16:00:00+00:00 TriggerDagRunOperator 2021-05-10T17:10:10.860845+00:00 2021-05-10T17:10:11.395288+00:00 0:00:00.534443 26617 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T17:10:08.589565+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T16:00:00+00:00 TriggerDagRunOperator 2021-05-10T17:10:10.787124+00:00 2021-05-10T17:10:11.202028+00:00 0:00:00.414904 26616 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T17:10:08.589539+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-10T16:05:00+00:00 EmrJobFlowSensor 2021-05-10T17:06:06.567618+00:00 2021-05-10T17:15:09.192736+00:00 0:09:02.625118 26615 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T17:06:04.277474+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-10T16:05:00+00:00 EmrCreateJobFlowOperator 2021-05-10T17:05:44.630460+00:00 2021-05-10T17:05:46.340888+00:00 0:00:01.710428 26614 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T17:05:42.278917+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-10T16:05:00+00:00 PythonOperator 2021-05-10T17:05:22.618556+00:00 2021-05-10T17:05:25.639587+00:00 0:00:03.021031 26613 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T17:05:20.205205+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T16:00:00+00:00 EmrJobFlowSensor 2021-05-10T17:00:56.056562+00:00 2021-05-10T17:09:58.809684+00:00 0:09:02.753122 26611 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T17:00:53.579757+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T17:00:35.705955+00:00 2021-05-10T17:00:37.432747+00:00 0:00:01.726792 26610 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T17:00:33.520528+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T16:00:00+00:00 PythonOperator 2021-05-10T17:00:13.680992+00:00 2021-05-10T17:00:16.925015+00:00 0:00:03.244023 26609 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T17:00:11.498391+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-10T15:00:00+00:00 EmrJobFlowSensor 2021-05-10T16:12:05.907223+00:00 2021-05-10T16:21:08.852309+00:00 0:09:02.945086 26608 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T16:12:03.634019+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-10T15:00:00+00:00 EmrJobFlowSensor 2021-05-10T16:11:57.763245+00:00 2021-05-10T16:22:00.549803+00:00 0:10:02.786558 26607 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T16:11:55.630242+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-10T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T16:11:43.838147+00:00 2021-05-10T16:11:45.583213+00:00 0:00:01.745066 26606 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T16:11:41.621915+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-10T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T16:11:35.998313+00:00 2021-05-10T16:11:37.807447+00:00 0:00:01.809134 26605 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T16:11:33.610762+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-10T15:00:00+00:00 PythonOperator 2021-05-10T16:11:22.133235+00:00 2021-05-10T16:11:25.198982+00:00 0:00:03.065747 26604 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T16:11:19.596546+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-10T15:00:00+00:00 PythonOperator 2021-05-10T16:11:14.275265+00:00 2021-05-10T16:11:17.570532+00:00 0:00:03.295267 26603 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T16:11:11.662847+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T15:00:00+00:00 TriggerDagRunOperator 2021-05-10T16:11:08.076844+00:00 2021-05-10T16:11:08.635600+00:00 0:00:00.558756 26602 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T16:11:05.659238+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T15:00:00+00:00 TriggerDagRunOperator 2021-05-10T16:11:07.867326+00:00 2021-05-10T16:11:08.315090+00:00 0:00:00.447764 26601 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T16:11:05.659187+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-10T15:05:00+00:00 EmrJobFlowSensor 2021-05-10T16:06:07.585108+00:00 2021-05-10T16:15:10.285870+00:00 0:09:02.700762 26600 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T16:06:05.167752+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-10T15:05:00+00:00 EmrCreateJobFlowOperator 2021-05-10T16:05:45.268720+00:00 2021-05-10T16:05:46.895539+00:00 0:00:01.626819 26599 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T16:05:43.103916+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-10T15:05:00+00:00 PythonOperator 2021-05-10T16:05:25.202210+00:00 2021-05-10T16:05:28.263659+00:00 0:00:03.061449 26598 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T16:05:23.062995+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T15:00:00+00:00 EmrJobFlowSensor 2021-05-10T16:02:01.073905+00:00 2021-05-10T16:11:03.874414+00:00 0:09:02.800509 26597 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T16:01:58.699144+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T16:01:36.868394+00:00 2021-05-10T16:01:38.549659+00:00 0:00:01.681265 26596 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T16:01:34.647724+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T15:00:00+00:00 PythonOperator 2021-05-10T16:00:21.417177+00:00 2021-05-10T16:00:24.525142+00:00 0:00:03.107965 26594 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T16:00:19.306345+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-10T14:00:00+00:00 EmrJobFlowSensor 2021-05-10T15:12:47.933070+00:00 2021-05-10T15:20:50.449618+00:00 0:08:02.516548 26593 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T15:12:45.698246+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-10T14:00:00+00:00 EmrJobFlowSensor 2021-05-10T15:12:44.062650+00:00 2021-05-10T15:22:46.995351+00:00 0:10:02.932701 26592 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T15:12:41.706228+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-10T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T15:12:25.943160+00:00 2021-05-10T15:12:27.723867+00:00 0:00:01.780707 26591 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T15:12:23.748744+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-10T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T15:12:21.971041+00:00 2021-05-10T15:12:23.722391+00:00 0:00:01.751350 26590 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T15:12:19.680192+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-10T14:00:00+00:00 PythonOperator 2021-05-10T15:12:02.102980+00:00 2021-05-10T15:12:05.203429+00:00 0:00:03.100449 26589 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T15:11:59.671081+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-10T14:00:00+00:00 PythonOperator 2021-05-10T15:11:47.789491+00:00 2021-05-10T15:11:51.078683+00:00 0:00:03.289192 26588 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T15:11:45.595429+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T14:00:00+00:00 TriggerDagRunOperator 2021-05-10T15:11:38.311093+00:00 2021-05-10T15:11:38.773940+00:00 0:00:00.462847 26587 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T15:11:35.647100+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T14:00:00+00:00 TriggerDagRunOperator 2021-05-10T15:11:38.034762+00:00 2021-05-10T15:11:38.593775+00:00 0:00:00.559013 26586 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T15:11:35.647052+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-10T14:05:00+00:00 EmrJobFlowSensor 2021-05-10T15:05:46.782995+00:00 2021-05-10T15:14:49.415128+00:00 0:09:02.632133 26585 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T15:05:44.619607+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-10T14:05:00+00:00 EmrCreateJobFlowOperator 2021-05-10T15:05:24.905063+00:00 2021-05-10T15:05:26.651958+00:00 0:00:01.746895 26584 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T15:05:22.606154+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-10T14:05:00+00:00 PythonOperator 2021-05-10T15:05:04.801564+00:00 2021-05-10T15:05:07.895078+00:00 0:00:03.093514 26583 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T15:05:02.646370+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T14:00:00+00:00 EmrJobFlowSensor 2021-05-10T15:01:22.618906+00:00 2021-05-10T15:11:25.585679+00:00 0:10:02.966773 26582 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T15:01:20.152819+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T15:01:00.940125+00:00 2021-05-10T15:01:02.764123+00:00 0:00:01.823998 26581 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T15:00:58.161720+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T14:00:00+00:00 PythonOperator 2021-05-10T15:00:40.352849+00:00 2021-05-10T15:00:43.471623+00:00 0:00:03.118774 26580 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T15:00:37.998572+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-10T13:00:00+00:00 EmrJobFlowSensor 2021-05-10T14:12:10.880025+00:00 2021-05-10T14:21:13.666540+00:00 0:09:02.786515 26578 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T14:12:08.655506+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-10T13:00:00+00:00 EmrJobFlowSensor 2021-05-10T14:12:05.083376+00:00 2021-05-10T14:20:07.639836+00:00 0:08:02.556460 26577 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T14:12:02.775701+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-10T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T14:11:49.048511+00:00 2021-05-10T14:11:50.852551+00:00 0:00:01.804040 26576 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T14:11:46.665850+00:00 2 default_pool