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 create_cluster_and_add_emr_steps 2021-03-22T15:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T16:11:16.022530+00:00 2021-03-22T16:11:17.776655+00:00 0:00:01.754125 10598 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T16:11:13.752009+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-22T15:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T16:11:16.046710+00:00 2021-03-22T16:11:17.986939+00:00 0:00:01.940229 10597 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T16:11:13.752056+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-22T15:00:00+00:00 PythonOperator 2021-03-22T16:10:54.284514+00:00 2021-03-22T16:10:57.398809+00:00 0:00:03.114295 10596 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T16:10:51.734118+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-22T15:00:00+00:00 PythonOperator 2021-03-22T16:10:54.147493+00:00 2021-03-22T16:10:57.050074+00:00 0:00:02.902581 10595 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T16:10:51.734153+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T15:00:00+00:00 TriggerDagRunOperator 2021-03-22T16:10:44.138312+00:00 2021-03-22T16:10:44.548474+00:00 0:00:00.410162 10594 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T16:10:41.721497+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T15:00:00+00:00 TriggerDagRunOperator 2021-03-22T16:10:43.932985+00:00 2021-03-22T16:10:44.444482+00:00 0:00:00.511497 10593 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T16:10:41.721545+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-22T15:05:00+00:00 EmrJobFlowSensor 2021-03-22T16:05:49.746565+00:00 2021-03-22T16:15:52.343386+00:00 0:10:02.596821 10592 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T16:05:47.463721+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-22T15:05:00+00:00 EmrCreateJobFlowOperator 2021-03-22T16:05:29.593969+00:00 2021-03-22T16:05:31.303742+00:00 0:00:01.709773 10591 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T16:05:27.355578+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-22T15:05:00+00:00 PythonOperator 2021-03-22T16:05:07.442990+00:00 2021-03-22T16:05:10.136316+00:00 0:00:02.693326 10590 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T16:05:05.335987+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T15:00:00+00:00 EmrJobFlowSensor 2021-03-22T16:01:19.299123+00:00 2021-03-22T16:10:21.953417+00:00 0:09:02.654294 10589 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T16:01:17.055807+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T15:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T16:00:59.207235+00:00 2021-03-22T16:01:00.982374+00:00 0:00:01.775139 10588 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T16:00:56.949977+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T15:00:00+00:00 PythonOperator 2021-03-22T16:00:37.742429+00:00 2021-03-22T16:00:40.545175+00:00 0:00:02.802746 10587 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T16:00:35.016374+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-22T14:00:00+00:00 EmrJobFlowSensor 2021-03-22T15:11:30.409695+00:00 2021-03-22T15:19:32.957951+00:00 0:08:02.548256 10585 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T15:11:28.040927+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-22T14:00:00+00:00 EmrJobFlowSensor 2021-03-22T15:11:07.990206+00:00 2021-03-22T15:44:13.870999+00:00 0:33:05.880793 10584 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T15:11:05.840434+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-22T14:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T15:11:02.021300+00:00 2021-03-22T15:11:03.696097+00:00 0:00:01.674797 10583 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T15:10:59.833569+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-22T14:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T15:10:38.184790+00:00 2021-03-22T15:10:39.989138+00:00 0:00:01.804348 10582 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T15:10:35.810471+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-22T14:00:00+00:00 PythonOperator 2021-03-22T15:10:32.187217+00:00 2021-03-22T15:10:35.063306+00:00 0:00:02.876089 10581 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T15:10:29.869559+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-22T14:00:00+00:00 PythonOperator 2021-03-22T15:10:16.087466+00:00 2021-03-22T15:10:19.098036+00:00 0:00:03.010570 10580 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T15:10:13.797726+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T14:00:00+00:00 TriggerDagRunOperator 2021-03-22T15:10:12.088810+00:00 2021-03-22T15:10:12.626399+00:00 0:00:00.537589 10579 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T15:10:09.791566+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T14:00:00+00:00 TriggerDagRunOperator 2021-03-22T15:10:12.054796+00:00 2021-03-22T15:10:12.437866+00:00 0:00:00.383070 10578 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T15:10:09.791601+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-22T14:05:00+00:00 EmrJobFlowSensor 2021-03-22T15:06:02.086190+00:00 2021-03-22T15:16:04.915572+00:00 0:10:02.829382 10577 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T15:05:59.646495+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-22T14:05:00+00:00 EmrCreateJobFlowOperator 2021-03-22T15:05:39.669671+00:00 2021-03-22T15:05:41.297292+00:00 0:00:01.627621 10576 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T15:05:37.407713+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-22T14:05:00+00:00 PythonOperator 2021-03-22T15:05:19.575757+00:00 2021-03-22T15:05:22.234534+00:00 0:00:02.658777 10575 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T15:05:17.385685+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T14:00:00+00:00 EmrJobFlowSensor 2021-03-22T15:01:05.442543+00:00 2021-03-22T15:10:08.176205+00:00 0:09:02.733662 10574 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T15:01:03.049192+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T14:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T15:00:43.093915+00:00 2021-03-22T15:00:44.775905+00:00 0:00:01.681990 10573 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T15:00:40.987301+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T14:00:00+00:00 PythonOperator 2021-03-22T15:00:21.111108+00:00 2021-03-22T15:00:23.829549+00:00 0:00:02.718441 10572 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T15:00:18.885284+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-22T14:26:26.975226+00:00 EmrJobFlowSensor 2021-03-22T14:27:27.411368+00:00 2021-03-22T14:57:32.703355+00:00 0:30:05.291987 10570 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T14:27:25.275888+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-22T14:26:26.975226+00:00 EmrCreateJobFlowOperator 2021-03-22T14:27:05.672411+00:00 2021-03-22T14:27:07.377095+00:00 0:00:01.704684 10569 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T14:27:03.256083+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-22T14:26:26.975226+00:00 PythonOperator 2021-03-22T14:26:31.529350+00:00 2021-03-22T14:26:34.547761+00:00 0:00:03.018411 10568 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T14:26:29.273683+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-22T14:13:06.041896+00:00 EmrJobFlowSensor 2021-03-22T14:14:03.997357+00:00 2021-03-22T14:24:06.676503+00:00 0:10:02.679146 10567 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T14:14:01.812410+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-22T14:13:06.041896+00:00 EmrCreateJobFlowOperator 2021-03-22T14:13:44.045595+00:00 2021-03-22T14:13:45.753436+00:00 0:00:01.707841 10566 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T14:13:41.796801+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-22T14:13:06.041896+00:00 PythonOperator 2021-03-22T14:13:21.875275+00:00 2021-03-22T14:13:24.541522+00:00 0:00:02.666247 10565 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T14:13:19.731436+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-22T13:00:00+00:00 EmrJobFlowSensor 2021-03-22T14:11:11.618688+00:00 2021-03-22T14:23:14.679256+00:00 0:12:03.060568 10564 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T14:11:09.493253+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-22T13:00:00+00:00 EmrJobFlowSensor 2021-03-22T14:11:05.890740+00:00 2021-03-22T14:20:08.479907+00:00 0:09:02.589167 10563 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T14:11:03.490656+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-22T13:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T14:10:49.792154+00:00 2021-03-22T14:10:51.504158+00:00 0:00:01.712004 10562 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T14:10:47.457540+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-22T13:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T14:10:41.684436+00:00 2021-03-22T14:10:43.483715+00:00 0:00:01.799279 10561 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T14:10:39.456033+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-22T13:00:00+00:00 PythonOperator 2021-03-22T14:10:27.640887+00:00 2021-03-22T14:10:30.724089+00:00 0:00:03.083202 10560 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T14:10:25.359689+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-22T13:00:00+00:00 PythonOperator 2021-03-22T14:10:21.616365+00:00 2021-03-22T14:10:24.322486+00:00 0:00:02.706121 10559 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T14:10:19.348840+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T13:00:00+00:00 TriggerDagRunOperator 2021-03-22T14:10:13.601321+00:00 2021-03-22T14:10:14.114788+00:00 0:00:00.513467 10558 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T14:10:11.341145+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T13:00:00+00:00 TriggerDagRunOperator 2021-03-22T14:10:13.564767+00:00 2021-03-22T14:10:13.999064+00:00 0:00:00.434297 10557 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T14:10:11.341117+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-22T13:05:00+00:00 EmrJobFlowSensor 2021-03-22T14:06:05.201310+00:00 2021-03-22T14:17:08.072242+00:00 0:11:02.870932 10556 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T14:06:02.919719+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-22T13:05:00+00:00 EmrCreateJobFlowOperator 2021-03-22T14:05:43.124328+00:00 2021-03-22T14:05:44.877736+00:00 0:00:01.753408 10555 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T14:05:40.890784+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-22T13:05:00+00:00 PythonOperator 2021-03-22T14:05:20.903996+00:00 2021-03-22T14:05:23.686452+00:00 0:00:02.782456 10554 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T14:05:18.786194+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T13:00:00+00:00 EmrJobFlowSensor 2021-03-22T14:00:52.602752+00:00 2021-03-22T14:09:55.254990+00:00 0:09:02.652238 10553 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T14:00:50.312799+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T13:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T14:00:30.909070+00:00 2021-03-22T14:00:32.594054+00:00 0:00:01.684984 10552 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T14:00:28.373202+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T13:00:00+00:00 PythonOperator 2021-03-22T14:00:08.583858+00:00 2021-03-22T14:00:11.455505+00:00 0:00:02.871647 10551 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T14:00:06.246899+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-22T12:00:00+00:00 EmrJobFlowSensor 2021-03-22T13:13:04.855332+00:00 2021-03-22T13:17:06.775025+00:00 0:04:01.919693 10549 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T13:13:02.684831+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-22T12:00:00+00:00 EmrJobFlowSensor 2021-03-22T13:12:40.913069+00:00 2021-03-22T13:22:43.653991+00:00 0:10:02.740922 10548 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T13:12:38.650680+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-22T12:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T13:12:38.919465+00:00 2021-03-22T13:12:40.596594+00:00 0:00:01.677129 10547 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T13:12:36.674618+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-22T12:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T13:12:21.341782+00:00 2021-03-22T13:12:23.325037+00:00 0:00:01.983255 10546 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T13:12:18.603432+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-22T12:00:00+00:00 PythonOperator 2021-03-22T13:12:19.091316+00:00 2021-03-22T13:12:22.492122+00:00 0:00:03.400806 10545 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T13:12:16.658302+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-22T12:00:00+00:00 PythonOperator 2021-03-22T13:11:59.352287+00:00 2021-03-22T13:12:02.168841+00:00 0:00:02.816554 10544 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T13:11:56.556573+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-22T10:00:00+00:00 PythonOperator 2021-03-22T13:11:56.963158+00:00 2021-03-22T13:12:00.368337+00:00 0:00:03.405179 10543 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T13:11:54.557232+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-22T08:00:00+00:00 PythonOperator 2021-03-22T13:11:56.807648+00:00 2021-03-22T13:11:59.741363+00:00 0:00:02.933715 10542 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T13:11:54.557265+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T12:00:00+00:00 TriggerDagRunOperator 2021-03-22T13:11:41.090361+00:00 2021-03-22T13:11:41.622775+00:00 0:00:00.532414 10541 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T13:11:38.552556+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T12:00:00+00:00 TriggerDagRunOperator 2021-03-22T13:11:40.964678+00:00 2021-03-22T13:11:41.388581+00:00 0:00:00.423903 10540 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T13:11:38.552513+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-22T07:00:00+00:00 PythonOperator 2021-03-22T13:11:35.080222+00:00 2021-03-22T13:11:38.159433+00:00 0:00:03.079211 10539 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T13:11:32.558758+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-21T12:00:00+00:00 PythonOperator 2021-03-22T13:09:12.437694+00:00 2021-03-22T13:09:15.461129+00:00 0:00:03.023435 10536 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T13:09:10.239849+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-21T06:00:00+00:00 PythonOperator 2021-03-22T13:08:26.645012+00:00 2021-03-22T13:08:29.660354+00:00 0:00:03.015342 10535 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T13:08:24.289948+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-21T05:00:00+00:00 PythonOperator 2021-03-22T13:08:02.635350+00:00 2021-03-22T13:08:05.661233+00:00 0:00:03.025883 10534 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T13:08:00.245748+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-20T17:00:00+00:00 PythonOperator 2021-03-22T13:06:30.739012+00:00 2021-03-22T13:06:33.670342+00:00 0:00:02.931330 10531 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T13:06:28.144570+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-20T14:00:00+00:00 PythonOperator 2021-03-22T13:06:08.220183+00:00 2021-03-22T13:06:11.240658+00:00 0:00:03.020475 10530 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T13:06:05.932680+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-22T12:05:00+00:00 EmrJobFlowSensor 2021-03-22T13:05:48.701852+00:00 2021-03-22T13:14:51.161535+00:00 0:09:02.459683 10529 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T13:05:45.921263+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-20T12:00:00+00:00 PythonOperator 2021-03-22T13:05:46.319378+00:00 2021-03-22T13:05:50.251940+00:00 0:00:03.932562 10528 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T13:05:43.915453+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-22T12:05:00+00:00 EmrCreateJobFlowOperator 2021-03-22T13:05:26.263678+00:00 2021-03-22T13:05:27.916238+00:00 0:00:01.652560 10527 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T13:05:23.969483+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-22T12:05:00+00:00 PythonOperator 2021-03-22T13:05:04.149722+00:00 2021-03-22T13:05:06.932288+00:00 0:00:02.782566 10526 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T13:05:01.888856+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-20T05:00:00+00:00 PythonOperator 2021-03-22T13:05:00.177887+00:00 2021-03-22T13:05:03.165314+00:00 0:00:02.987427 10525 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T13:04:57.863445+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-20T03:00:00+00:00 PythonOperator 2021-03-22T13:04:38.244082+00:00 2021-03-22T13:04:41.173442+00:00 0:00:02.929360 10524 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T13:04:35.814719+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-20T02:00:00+00:00 PythonOperator 2021-03-22T13:04:09.976613+00:00 2021-03-22T13:04:12.948114+00:00 0:00:02.971501 10523 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T13:04:07.795140+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-19T17:00:00+00:00 PythonOperator 2021-03-22T13:01:39.890579+00:00 2021-03-22T13:01:42.910335+00:00 0:00:03.019756 10522 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T13:01:37.593507+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-19T16:00:00+00:00 EmrJobFlowSensor 2021-03-22T13:01:39.880597+00:00 2021-03-22T13:31:45.303826+00:00 0:30:05.423229 10521 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T13:01:37.593538+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-19T16:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T13:01:17.769042+00:00 2021-03-22T13:01:19.597604+00:00 0:00:01.828562 10520 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T13:01:15.528205+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T12:00:00+00:00 EmrJobFlowSensor 2021-03-22T13:01:13.877979+00:00 2021-03-22T13:11:16.731482+00:00 0:10:02.853503 10519 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T13:01:11.578717+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-19T16:00:00+00:00 PythonOperator 2021-03-22T13:00:53.948469+00:00 2021-03-22T13:00:57.050649+00:00 0:00:03.102180 10518 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T13:00:51.505287+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T12:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T13:00:53.761350+00:00 2021-03-22T13:00:55.716424+00:00 0:00:01.955074 10517 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T13:00:51.505315+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T12:00:00+00:00 PythonOperator 2021-03-22T13:00:32.188613+00:00 2021-03-22T13:00:35.046414+00:00 0:00:02.857801 10516 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T13:00:29.559785+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-22T11:05:00+00:00 EmrJobFlowSensor 2021-03-22T12:18:30.676142+00:00 2021-03-22T12:27:33.360394+00:00 0:09:02.684252 10514 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T12:18:28.258063+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-22T11:05:00+00:00 EmrCreateJobFlowOperator 2021-03-22T12:18:00.434649+00:00 2021-03-22T12:18:02.182756+00:00 0:00:01.748107 10513 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T12:17:58.174638+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-22T11:05:00+00:00 PythonOperator 2021-03-22T12:17:38.481658+00:00 2021-03-22T12:17:41.184259+00:00 0:00:02.702601 10512 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T12:17:36.165712+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-22T11:00:00+00:00 EmrJobFlowSensor 2021-03-22T12:12:08.109408+00:00 2021-03-22T12:21:10.911786+00:00 0:09:02.802378 10511 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T12:12:05.621417+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-22T11:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T12:11:33.777918+00:00 2021-03-22T12:11:35.500450+00:00 0:00:01.722532 10510 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T12:11:31.588624+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-22T11:00:00+00:00 PythonOperator 2021-03-22T12:11:11.741361+00:00 2021-03-22T12:11:14.531840+00:00 0:00:02.790479 10509 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T12:11:09.549654+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T11:00:00+00:00 TriggerDagRunOperator 2021-03-22T12:11:06.114711+00:00 2021-03-22T12:11:06.621258+00:00 0:00:00.506547 10508 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T12:11:03.560865+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T11:00:00+00:00 TriggerDagRunOperator 2021-03-22T12:11:05.867996+00:00 2021-03-22T12:11:06.256655+00:00 0:00:00.388659 10507 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T12:11:03.560829+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T11:00:00+00:00 EmrJobFlowSensor 2021-03-22T12:00:53.021475+00:00 2021-03-22T12:10:55.926430+00:00 0:10:02.904955 10506 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T12:00:50.651694+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T11:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T12:00:31.205093+00:00 2021-03-22T12:00:32.918650+00:00 0:00:01.713557 10505 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T12:00:28.843212+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T11:00:00+00:00 PythonOperator 2021-03-22T12:00:09.008214+00:00 2021-03-22T12:00:11.757483+00:00 0:00:02.749269 10504 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T12:00:06.603122+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-22T10:00:00+00:00 EmrJobFlowSensor 2021-03-22T11:10:51.215432+00:00 2021-03-22T11:19:53.769931+00:00 0:09:02.554499 10502 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T11:10:48.996914+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-22T10:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T11:10:29.161229+00:00 2021-03-22T11:10:30.963712+00:00 0:00:01.802483 10501 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T11:10:26.959410+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-22T10:00:00+00:00 PythonOperator 2021-03-22T11:10:07.204140+00:00 2021-03-22T11:10:09.928655+00:00 0:00:02.724515 10500 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T11:10:04.917392+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T10:00:00+00:00 TriggerDagRunOperator 2021-03-22T11:09:57.248241+00:00 2021-03-22T11:09:57.662552+00:00 0:00:00.414311 10499 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T11:09:54.916021+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T10:00:00+00:00 TriggerDagRunOperator 2021-03-22T11:09:57.195953+00:00 2021-03-22T11:09:57.753350+00:00 0:00:00.557397 10498 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T11:09:54.915979+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T10:00:00+00:00 EmrJobFlowSensor 2021-03-22T11:00:48.478256+00:00 2021-03-22T11:09:51.248483+00:00 0:09:02.770227 10497 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T11:00:46.119802+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T10:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T11:00:26.665293+00:00 2021-03-22T11:00:28.499333+00:00 0:00:01.834040 10496 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T11:00:24.158024+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T10:00:00+00:00 PythonOperator 2021-03-22T11:00:06.589460+00:00 2021-03-22T11:00:09.484445+00:00 0:00:02.894985 10495 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T11:00:04.086721+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-22T09:00:00+00:00 EmrJobFlowSensor 2021-03-22T10:11:12.663633+00:00 2021-03-22T10:20:15.369209+00:00 0:09:02.705576 10493 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T10:11:10.239426+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-22T09:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T10:10:56.285973+00:00 2021-03-22T10:10:57.965790+00:00 0:00:01.679817 10492 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T10:10:54.165399+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-22T09:00:00+00:00 PythonOperator 2021-03-22T10:10:40.351395+00:00 2021-03-22T10:10:43.201457+00:00 0:00:02.850062 10491 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T10:10:38.098612+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T09:00:00+00:00 TriggerDagRunOperator 2021-03-22T10:10:23.023256+00:00 2021-03-22T10:10:23.742718+00:00 0:00:00.719462 10490 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T10:10:20.136821+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T09:00:00+00:00 TriggerDagRunOperator 2021-03-22T10:10:22.634182+00:00 2021-03-22T10:10:23.054005+00:00 0:00:00.419823 10489 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T10:10:20.136775+00:00 2 default_pool