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_booking-processing-job_v002 2021-04-02T14:00:00+00:00 TriggerDagRunOperator 2021-04-02T15:09:15.732656+00:00 2021-04-02T15:09:16.244342+00:00 0:00:00.511686 12800 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T15:09:13.346760+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T14:00:00+00:00 TriggerDagRunOperator 2021-04-02T15:09:15.725679+00:00 2021-04-02T15:09:16.379065+00:00 0:00:00.653386 12799 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T15:09:13.346727+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-02T14:05:00+00:00 EmrJobFlowSensor 2021-04-02T15:05:57.027312+00:00 2021-04-02T15:14:59.622601+00:00 0:09:02.595289 12798 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T15:05:54.903052+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-02T14:05:00+00:00 EmrCreateJobFlowOperator 2021-04-02T15:05:35.115876+00:00 2021-04-02T15:05:36.840420+00:00 0:00:01.724544 12797 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T15:05:32.884546+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-02T14:05:00+00:00 PythonOperator 2021-04-02T15:05:13.053476+00:00 2021-04-02T15:05:15.758257+00:00 0:00:02.704781 12796 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T15:05:10.831470+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T14:00:00+00:00 EmrJobFlowSensor 2021-04-02T15:00:58.621024+00:00 2021-04-02T15:09:01.257629+00:00 0:08:02.636605 12795 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T15:00:56.427880+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T15:00:38.894777+00:00 2021-04-02T15:00:40.720580+00:00 0:00:01.825803 12794 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T15:00:36.407657+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T14:00:00+00:00 PythonOperator 2021-04-02T15:00:16.910955+00:00 2021-04-02T15:00:19.791853+00:00 0:00:02.880898 12793 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T15:00:14.456112+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-02T13:00:00+00:00 EmrJobFlowSensor 2021-04-02T14:14:40.316608+00:00 2021-04-02T14:22:42.816445+00:00 0:08:02.499837 12792 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T14:14:37.955988+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-02T13:00:00+00:00 EmrJobFlowSensor 2021-04-02T14:14:30.218211+00:00 2021-04-02T14:24:33.037663+00:00 0:10:02.819452 12791 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T14:14:27.843312+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-02T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T14:14:18.020734+00:00 2021-04-02T14:14:19.772704+00:00 0:00:01.751970 12790 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T14:14:15.821810+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-02T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T14:14:08.262936+00:00 2021-04-02T14:14:10.086851+00:00 0:00:01.823915 12789 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T14:14:05.809474+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-02T13:00:00+00:00 PythonOperator 2021-04-02T14:13:58.100595+00:00 2021-04-02T14:14:00.774893+00:00 0:00:02.674298 12788 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T14:13:55.799440+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-02T13:00:00+00:00 PythonOperator 2021-04-02T14:13:48.134805+00:00 2021-04-02T14:13:51.092864+00:00 0:00:02.958059 12787 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T14:13:45.789573+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T13:00:00+00:00 TriggerDagRunOperator 2021-04-02T14:13:40.544413+00:00 2021-04-02T14:13:41.068122+00:00 0:00:00.523709 12786 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T14:13:37.696784+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T13:00:00+00:00 TriggerDagRunOperator 2021-04-02T14:13:40.428379+00:00 2021-04-02T14:13:40.891127+00:00 0:00:00.462748 12785 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T14:13:37.696816+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-02T13:05:00+00:00 EmrJobFlowSensor 2021-04-02T14:05:46.886601+00:00 2021-04-02T14:14:49.562961+00:00 0:09:02.676360 12783 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T14:05:44.645354+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-02T13:05:00+00:00 EmrCreateJobFlowOperator 2021-04-02T14:05:26.841957+00:00 2021-04-02T14:05:28.574271+00:00 0:00:01.732314 12782 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T14:05:24.538064+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-02T13:05:00+00:00 PythonOperator 2021-04-02T14:05:04.913764+00:00 2021-04-02T14:05:07.575146+00:00 0:00:02.661382 12781 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T14:05:02.572683+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T13:00:00+00:00 EmrJobFlowSensor 2021-04-02T14:00:50.385122+00:00 2021-04-02T14:10:53.370776+00:00 0:10:02.985654 12780 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T14:00:48.157528+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T14:00:28.602753+00:00 2021-04-02T14:00:30.427232+00:00 0:00:01.824479 12779 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T14:00:26.173297+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T13:00:00+00:00 PythonOperator 2021-04-02T14:00:08.397686+00:00 2021-04-02T14:00:11.154235+00:00 0:00:02.756549 12778 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T14:00:06.149043+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-02T12:00:00+00:00 EmrJobFlowSensor 2021-04-02T13:12:19.170408+00:00 2021-04-02T13:22:21.943968+00:00 0:10:02.773560 12777 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T13:12:16.506176+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-02T12:00:00+00:00 EmrJobFlowSensor 2021-04-02T13:12:16.718247+00:00 2021-04-02T13:21:19.737383+00:00 0:09:03.019136 12776 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T13:12:14.508903+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-02T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T13:11:57.021311+00:00 2021-04-02T13:11:58.792769+00:00 0:00:01.771458 12775 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T13:11:54.546731+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-02T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T13:11:55.099650+00:00 2021-04-02T13:11:56.793575+00:00 0:00:01.693925 12774 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T13:11:52.490538+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-02T12:00:00+00:00 PythonOperator 2021-04-02T13:11:37.454082+00:00 2021-04-02T13:11:40.362552+00:00 0:00:02.908470 12773 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T13:11:34.477398+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-02T12:00:00+00:00 PythonOperator 2021-04-02T13:11:32.785186+00:00 2021-04-02T13:11:36.178337+00:00 0:00:03.393151 12772 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T13:11:30.475552+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T12:00:00+00:00 TriggerDagRunOperator 2021-04-02T13:11:27.328018+00:00 2021-04-02T13:11:27.841904+00:00 0:00:00.513886 12771 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T13:11:24.250815+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T12:00:00+00:00 TriggerDagRunOperator 2021-04-02T13:11:27.112662+00:00 2021-04-02T13:11:27.544956+00:00 0:00:00.432294 12770 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T13:11:24.250859+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-02T12:05:00+00:00 EmrJobFlowSensor 2021-04-02T13:06:04.862674+00:00 2021-04-02T13:14:07.434846+00:00 0:08:02.572172 12768 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T13:06:02.459255+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-02T12:05:00+00:00 EmrCreateJobFlowOperator 2021-04-02T13:05:42.530629+00:00 2021-04-02T13:05:44.284438+00:00 0:00:01.753809 12767 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T13:05:40.316100+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-02T12:05:00+00:00 PythonOperator 2021-04-02T13:05:22.484969+00:00 2021-04-02T13:05:25.154582+00:00 0:00:02.669613 12766 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T13:05:20.299305+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T12:00:00+00:00 EmrJobFlowSensor 2021-04-02T13:01:06.130918+00:00 2021-04-02T13:11:09.022565+00:00 0:10:02.891647 12765 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T13:01:03.891095+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T13:00:44.389820+00:00 2021-04-02T13:00:46.212868+00:00 0:00:01.823048 12764 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T13:00:41.846724+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T12:00:00+00:00 PythonOperator 2021-04-02T13:00:24.269985+00:00 2021-04-02T13:00:27.014844+00:00 0:00:02.744859 12763 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T13:00:21.828320+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-02T11:00:00+00:00 EmrJobFlowSensor 2021-04-02T12:11:26.921367+00:00 2021-04-02T12:19:29.579157+00:00 0:08:02.657790 12762 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T12:11:24.709032+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-02T11:00:00+00:00 EmrJobFlowSensor 2021-04-02T12:11:23.045606+00:00 2021-04-02T12:21:26.119976+00:00 0:10:03.074370 12761 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T12:11:20.705396+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-02T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T12:11:04.987732+00:00 2021-04-02T12:11:06.688871+00:00 0:00:01.701139 12760 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T12:11:02.687975+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-02T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T12:11:01.140821+00:00 2021-04-02T12:11:02.999189+00:00 0:00:01.858368 12759 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T12:10:58.756657+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-02T11:00:00+00:00 PythonOperator 2021-04-02T12:10:43.029611+00:00 2021-04-02T12:10:45.896559+00:00 0:00:02.866948 12758 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T12:10:40.671786+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-02T11:00:00+00:00 PythonOperator 2021-04-02T12:10:38.903303+00:00 2021-04-02T12:10:41.851726+00:00 0:00:02.948423 12757 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T12:10:36.686654+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T11:00:00+00:00 TriggerDagRunOperator 2021-04-02T12:10:23.014831+00:00 2021-04-02T12:10:23.611397+00:00 0:00:00.596566 12756 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T12:10:20.648208+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T11:00:00+00:00 TriggerDagRunOperator 2021-04-02T12:10:22.961913+00:00 2021-04-02T12:10:23.717311+00:00 0:00:00.755398 12755 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T12:10:20.648172+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-02T11:05:00+00:00 EmrJobFlowSensor 2021-04-02T12:07:03.089641+00:00 2021-04-02T12:15:05.565625+00:00 0:08:02.475984 12754 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T12:07:00.463472+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-02T11:05:00+00:00 EmrCreateJobFlowOperator 2021-04-02T12:05:42.185741+00:00 2021-04-02T12:05:43.888031+00:00 0:00:01.702290 12752 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T12:05:39.925482+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-02T11:05:00+00:00 PythonOperator 2021-04-02T12:05:22.334776+00:00 2021-04-02T12:05:25.120156+00:00 0:00:02.785380 12751 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T12:05:19.960258+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T11:00:00+00:00 EmrJobFlowSensor 2021-04-02T12:00:55.835701+00:00 2021-04-02T12:09:58.483537+00:00 0:09:02.647836 12750 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T12:00:53.497831+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T12:00:33.748113+00:00 2021-04-02T12:00:35.619507+00:00 0:00:01.871394 12749 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T12:00:31.467926+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T11:00:00+00:00 PythonOperator 2021-04-02T12:00:13.711940+00:00 2021-04-02T12:00:16.552626+00:00 0:00:02.840686 12748 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T12:00:11.446146+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-02T10:00:00+00:00 EmrJobFlowSensor 2021-04-02T11:18:04.009608+00:00 2021-04-02T11:30:07.086151+00:00 0:12:03.076543 12747 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T11:18:01.610556+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-02T10:00:00+00:00 EmrJobFlowSensor 2021-04-02T11:17:59.910409+00:00 2021-04-02T11:26:02.464646+00:00 0:08:02.554237 12746 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T11:17:57.657254+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-02T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T11:17:41.891033+00:00 2021-04-02T11:17:43.572600+00:00 0:00:01.681567 12745 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T11:17:39.593759+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-02T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T11:17:37.823293+00:00 2021-04-02T11:17:39.569882+00:00 0:00:01.746589 12744 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T11:17:35.606313+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-02T10:00:00+00:00 PythonOperator 2021-04-02T11:17:20.197067+00:00 2021-04-02T11:17:23.154946+00:00 0:00:02.957879 12743 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T11:17:17.548172+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-02T10:00:00+00:00 PythonOperator 2021-04-02T11:17:18.063930+00:00 2021-04-02T11:17:21.067634+00:00 0:00:03.003704 12742 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T11:17:15.551772+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T10:00:00+00:00 TriggerDagRunOperator 2021-04-02T11:17:07.890021+00:00 2021-04-02T11:17:08.453716+00:00 0:00:00.563695 12741 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T11:17:05.536078+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T10:00:00+00:00 TriggerDagRunOperator 2021-04-02T11:17:07.820343+00:00 2021-04-02T11:17:08.242677+00:00 0:00:00.422334 12740 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T11:17:05.536046+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-02T10:05:00+00:00 EmrJobFlowSensor 2021-04-02T11:06:59.201469+00:00 2021-04-02T11:16:01.871547+00:00 0:09:02.670078 12739 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T11:06:56.671961+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T10:00:00+00:00 EmrJobFlowSensor 2021-04-02T11:06:53.017134+00:00 2021-04-02T11:16:55.738134+00:00 0:10:02.721000 12738 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T11:06:50.661705+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-02T10:05:00+00:00 EmrCreateJobFlowOperator 2021-04-02T11:06:38.875619+00:00 2021-04-02T11:06:40.514580+00:00 0:00:01.638961 12737 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T11:06:36.584553+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T11:06:31.251215+00:00 2021-04-02T11:06:32.953802+00:00 0:00:01.702587 12736 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T11:06:28.660441+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-02T10:05:00+00:00 PythonOperator 2021-04-02T11:06:14.724033+00:00 2021-04-02T11:06:17.373011+00:00 0:00:02.648978 12735 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T11:06:12.525588+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T10:00:00+00:00 PythonOperator 2021-04-02T11:06:08.986307+00:00 2021-04-02T11:06:11.827470+00:00 0:00:02.841163 12734 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T11:06:06.509926+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-02T09:00:00+00:00 EmrJobFlowSensor 2021-04-02T10:11:10.249566+00:00 2021-04-02T10:21:13.026319+00:00 0:10:02.776753 12732 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T10:11:07.827311+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-02T09:00:00+00:00 EmrJobFlowSensor 2021-04-02T10:10:56.011821+00:00 2021-04-02T10:19:58.582838+00:00 0:09:02.571017 12731 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T10:10:53.745424+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-02T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T10:10:47.920872+00:00 2021-04-02T10:10:49.601820+00:00 0:00:01.680948 12730 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T10:10:45.732551+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-02T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T10:10:33.906909+00:00 2021-04-02T10:10:35.682414+00:00 0:00:01.775505 12729 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T10:10:31.718915+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-02T09:00:00+00:00 PythonOperator 2021-04-02T10:10:27.972311+00:00 2021-04-02T10:10:30.869664+00:00 0:00:02.897353 12728 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T10:10:25.721098+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-02T09:00:00+00:00 PythonOperator 2021-04-02T10:10:11.945821+00:00 2021-04-02T10:10:14.662637+00:00 0:00:02.716816 12727 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T10:10:09.701769+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T09:00:00+00:00 TriggerDagRunOperator 2021-04-02T10:10:02.365595+00:00 2021-04-02T10:10:02.917735+00:00 0:00:00.552140 12726 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T10:09:59.757512+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T09:00:00+00:00 TriggerDagRunOperator 2021-04-02T10:10:02.282973+00:00 2021-04-02T10:10:02.733031+00:00 0:00:00.450058 12725 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T10:09:59.757470+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-02T09:05:00+00:00 EmrJobFlowSensor 2021-04-02T10:06:00.064741+00:00 2021-04-02T10:15:02.781543+00:00 0:09:02.716802 12724 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T10:05:57.370054+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-02T09:05:00+00:00 EmrCreateJobFlowOperator 2021-04-02T10:05:37.676353+00:00 2021-04-02T10:05:39.325930+00:00 0:00:01.649577 12723 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T10:05:35.386853+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-02T09:05:00+00:00 PythonOperator 2021-04-02T10:05:17.489221+00:00 2021-04-02T10:05:20.177191+00:00 0:00:02.687970 12722 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T10:05:15.324324+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T09:00:00+00:00 EmrJobFlowSensor 2021-04-02T10:00:49.337984+00:00 2021-04-02T10:09:52.133984+00:00 0:09:02.796000 12721 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T10:00:46.950777+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T10:00:29.247624+00:00 2021-04-02T10:00:31.051850+00:00 0:00:01.804226 12720 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T10:00:26.848665+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T09:00:00+00:00 PythonOperator 2021-04-02T10:00:07.096809+00:00 2021-04-02T10:00:09.800667+00:00 0:00:02.703858 12719 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T10:00:04.831944+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-02T08:00:00+00:00 EmrJobFlowSensor 2021-04-02T09:12:11.077325+00:00 2021-04-02T09:21:13.830037+00:00 0:09:02.752712 12717 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T09:12:08.777822+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-02T08:00:00+00:00 EmrJobFlowSensor 2021-04-02T09:11:59.110793+00:00 2021-04-02T09:20:01.766960+00:00 0:08:02.656167 12716 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T09:11:56.707216+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-02T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T09:11:49.237556+00:00 2021-04-02T09:11:50.944355+00:00 0:00:01.706799 12715 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T09:11:46.752479+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-02T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T09:11:36.905980+00:00 2021-04-02T09:11:38.597481+00:00 0:00:01.691501 12714 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T09:11:34.690713+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-02T08:00:00+00:00 PythonOperator 2021-04-02T09:11:29.071183+00:00 2021-04-02T09:11:32.075956+00:00 0:00:03.004773 12713 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T09:11:26.656593+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-02T08:00:00+00:00 PythonOperator 2021-04-02T09:11:15.254304+00:00 2021-04-02T09:11:18.025911+00:00 0:00:02.771607 12712 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T09:11:12.648058+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T08:00:00+00:00 TriggerDagRunOperator 2021-04-02T09:11:07.099283+00:00 2021-04-02T09:11:07.550423+00:00 0:00:00.451140 12711 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T09:11:04.663719+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T08:00:00+00:00 TriggerDagRunOperator 2021-04-02T09:11:07.109499+00:00 2021-04-02T09:11:07.682388+00:00 0:00:00.572889 12710 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T09:11:04.663687+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-02T08:05:00+00:00 EmrJobFlowSensor 2021-04-02T09:05:52.204440+00:00 2021-04-02T09:14:54.903351+00:00 0:09:02.698911 12709 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T09:05:49.883780+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-02T08:05:00+00:00 EmrCreateJobFlowOperator 2021-04-02T09:05:31.963916+00:00 2021-04-02T09:05:33.603441+00:00 0:00:01.639525 12708 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T09:05:29.823629+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-02T08:05:00+00:00 PythonOperator 2021-04-02T09:05:10.067990+00:00 2021-04-02T09:05:12.780402+00:00 0:00:02.712412 12707 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T09:05:07.807300+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T08:00:00+00:00 EmrJobFlowSensor 2021-04-02T09:00:53.625739+00:00 2021-04-02T09:10:56.391087+00:00 0:10:02.765348 12706 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T09:00:51.419677+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T09:00:31.802460+00:00 2021-04-02T09:00:33.507334+00:00 0:00:01.704874 12705 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T09:00:29.459286+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T08:00:00+00:00 PythonOperator 2021-04-02T09:00:11.652756+00:00 2021-04-02T09:00:14.382514+00:00 0:00:02.729758 12704 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T09:00:09.384512+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-02T07:00:00+00:00 EmrJobFlowSensor 2021-04-02T08:11:16.343751+00:00 2021-04-02T08:19:18.977029+00:00 0:08:02.633278 12702 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T08:11:14.081247+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-02T07:00:00+00:00 EmrJobFlowSensor 2021-04-02T08:11:08.306435+00:00 2021-04-02T08:23:11.408930+00:00 0:12:03.102495 12701 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T08:11:06.042924+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-02T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T08:10:46.202284+00:00 2021-04-02T08:10:47.935638+00:00 0:00:01.733354 12700 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T08:10:44.023718+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-02T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T08:10:44.424875+00:00 2021-04-02T08:10:46.276937+00:00 0:00:01.852062 12699 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T08:10:42.025402+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-02T07:00:00+00:00 PythonOperator 2021-04-02T08:10:22.225627+00:00 2021-04-02T08:10:25.017670+00:00 0:00:02.792043 12698 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T08:10:20.002927+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-02T07:00:00+00:00 PythonOperator 2021-04-02T08:10:22.268757+00:00 2021-04-02T08:10:25.461501+00:00 0:00:03.192744 12697 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T08:10:20.002897+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T07:00:00+00:00 TriggerDagRunOperator 2021-04-02T08:10:16.329769+00:00 2021-04-02T08:10:16.843850+00:00 0:00:00.514081 12696 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T08:10:13.997629+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T07:00:00+00:00 TriggerDagRunOperator 2021-04-02T08:10:16.193497+00:00 2021-04-02T08:10:16.618600+00:00 0:00:00.425103 12695 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T08:10:13.997580+00:00 2 default_pool