Task Instances

Reset Filters
  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-02T03:00:00+00:00 TriggerDagRunOperator 2023-04-02T04:21:29.046915+00:00 2023-04-02T04:21:29.498412+00:00 0:00:00.451497 362773 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-02T04:21:26.311073+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-02T03:00:00+00:00 EmrJobFlowSensor 2023-04-02T04:11:14.790830+00:00 2023-04-02T04:21:16.623033+00:00 0:10:01.832203 362768 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-02T04:11:12.561339+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-02T03:00:00+00:00 EmrCreateJobFlowOperator 2023-04-02T04:10:53.294114+00:00 2023-04-02T04:10:54.625159+00:00 0:00:01.331045 362766 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-02T04:10:50.540889+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-02T03:00:00+00:00 PythonOperator 2023-04-02T04:10:31.248371+00:00 2023-04-02T04:10:37.260943+00:00 0:00:06.012572 362762 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-02T04:10:28.522199+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-02T02:00:00+00:00 TriggerDagRunOperator 2023-04-02T03:11:37.320441+00:00 2023-04-02T03:11:37.811750+00:00 0:00:00.491309 362754 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-02T03:11:34.251451+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-02T02:00:00+00:00 TriggerDagRunOperator 2023-04-02T03:11:37.002873+00:00 2023-04-02T03:11:37.460970+00:00 0:00:00.458097 362753 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-02T03:11:34.251422+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-02T02:00:00+00:00 EmrJobFlowSensor 2023-04-02T03:00:59.345668+00:00 2023-04-02T03:11:01.098513+00:00 0:10:01.752845 362745 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-02T03:00:57.204694+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-02T02:00:00+00:00 EmrCreateJobFlowOperator 2023-04-02T03:00:39.315268+00:00 2023-04-02T03:00:40.154012+00:00 0:00:00.838744 362743 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-02T03:00:37.189593+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-02T02:00:00+00:00 PythonOperator 2023-04-02T03:00:17.795352+00:00 2023-04-02T03:00:21.295322+00:00 0:00:03.499970 362741 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-02T03:00:15.166639+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-02T01:00:00+00:00 TriggerDagRunOperator 2023-04-02T02:13:27.126447+00:00 2023-04-02T02:13:27.638386+00:00 0:00:00.511939 362734 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-02T02:13:24.490135+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-02T01:00:00+00:00 TriggerDagRunOperator 2023-04-02T02:13:27.014928+00:00 2023-04-02T02:13:27.480141+00:00 0:00:00.465213 362733 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-02T02:13:24.490163+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-02T01:00:00+00:00 EmrJobFlowSensor 2023-04-02T02:02:59.969186+00:00 2023-04-02T02:13:02.097465+00:00 0:10:02.128279 362727 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-02T02:02:57.539228+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-02T01:00:00+00:00 EmrCreateJobFlowOperator 2023-04-02T02:02:37.696208+00:00 2023-04-02T02:02:38.499883+00:00 0:00:00.803675 362725 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-02T02:02:35.512844+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-02T01:00:00+00:00 PythonOperator 2023-04-02T02:02:15.632457+00:00 2023-04-02T02:02:19.615280+00:00 0:00:03.982823 362723 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-02T02:02:13.494832+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-02T00:00:00+00:00 TriggerDagRunOperator 2023-04-02T01:26:30.537081+00:00 2023-04-02T01:26:31.075517+00:00 0:00:00.538436 362708 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-02T01:26:27.636267+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-02T00:00:00+00:00 TriggerDagRunOperator 2023-04-02T01:26:30.388666+00:00 2023-04-02T01:26:30.911219+00:00 0:00:00.522553 362707 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-02T01:26:27.636238+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-02T00:00:00+00:00 EmrJobFlowSensor 2023-04-02T01:13:21.817315+00:00 2023-04-02T01:23:23.982668+00:00 0:10:02.165353 362702 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-02T01:13:19.315255+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-02T00:00:00+00:00 EmrCreateJobFlowOperator 2023-04-02T01:12:59.421983+00:00 2023-04-02T01:13:00.517490+00:00 0:00:01.095507 362699 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-02T01:12:57.286855+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-02T00:00:00+00:00 PythonOperator 2023-04-02T01:12:39.730532+00:00 2023-04-02T01:12:43.781806+00:00 0:00:04.051274 362696 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-02T01:12:37.317615+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-01T23:00:00+00:00 TriggerDagRunOperator 2023-04-02T00:20:57.272114+00:00 2023-04-02T00:20:57.799564+00:00 0:00:00.527450 362690 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-02T00:20:54.404183+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-01T23:00:00+00:00 TriggerDagRunOperator 2023-04-02T00:20:57.069224+00:00 2023-04-02T00:20:57.552545+00:00 0:00:00.483321 362689 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-02T00:20:54.404211+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-01T23:00:00+00:00 EmrJobFlowSensor 2023-04-02T00:08:43.595503+00:00 2023-04-02T00:18:45.274552+00:00 0:10:01.679049 362684 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-02T00:08:41.435414+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-01T23:00:00+00:00 EmrCreateJobFlowOperator 2023-04-02T00:08:21.923594+00:00 2023-04-02T00:08:22.761861+00:00 0:00:00.838267 362681 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-02T00:08:19.402786+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-01T23:00:00+00:00 PythonOperator 2023-04-02T00:08:02.341954+00:00 2023-04-02T00:08:06.809931+00:00 0:00:04.467977 362678 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-02T00:07:59.386652+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-01T22:00:00+00:00 TriggerDagRunOperator 2023-04-01T23:11:17.497475+00:00 2023-04-01T23:11:18.004055+00:00 0:00:00.506580 362669 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-01T23:11:14.608652+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-01T22:00:00+00:00 TriggerDagRunOperator 2023-04-01T23:11:17.245170+00:00 2023-04-01T23:11:17.689684+00:00 0:00:00.444514 362668 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-01T23:11:14.608611+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-01T22:00:00+00:00 EmrJobFlowSensor 2023-04-01T23:00:51.682056+00:00 2023-04-01T23:10:53.362513+00:00 0:10:01.680457 362661 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-01T23:00:49.432181+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-01T22:00:00+00:00 EmrCreateJobFlowOperator 2023-04-01T23:00:29.512841+00:00 2023-04-01T23:00:30.355250+00:00 0:00:00.842409 362657 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-01T23:00:27.333336+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-01T22:00:00+00:00 PythonOperator 2023-04-01T23:00:07.683669+00:00 2023-04-01T23:00:10.801315+00:00 0:00:03.117646 362655 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-01T23:00:05.264256+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-01T21:00:00+00:00 TriggerDagRunOperator 2023-04-01T22:11:26.512546+00:00 2023-04-01T22:11:26.984876+00:00 0:00:00.472330 362643 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-01T22:11:23.713145+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-01T21:00:00+00:00 TriggerDagRunOperator 2023-04-01T22:11:26.347866+00:00 2023-04-01T22:11:26.804859+00:00 0:00:00.456993 362642 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-01T22:11:23.713103+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-01T21:00:00+00:00 EmrJobFlowSensor 2023-04-01T22:01:03.395919+00:00 2023-04-01T22:11:05.207411+00:00 0:10:01.811492 362636 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-01T22:01:01.160122+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-01T21:00:00+00:00 EmrCreateJobFlowOperator 2023-04-01T22:00:42.535971+00:00 2023-04-01T22:00:43.385478+00:00 0:00:00.849507 362634 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-01T22:00:39.210892+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-01T21:00:00+00:00 PythonOperator 2023-04-01T22:00:19.528229+00:00 2023-04-01T22:00:22.905642+00:00 0:00:03.377413 362632 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-01T22:00:17.120508+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-01T20:00:00+00:00 TriggerDagRunOperator 2023-04-01T21:11:13.271945+00:00 2023-04-01T21:11:13.756282+00:00 0:00:00.484337 362619 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-01T21:11:10.299344+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-01T20:00:00+00:00 TriggerDagRunOperator 2023-04-01T21:11:13.139786+00:00 2023-04-01T21:11:13.591039+00:00 0:00:00.451253 362618 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-01T21:11:10.299382+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-01T20:00:00+00:00 EmrJobFlowSensor 2023-04-01T21:00:52.747858+00:00 2023-04-01T21:10:54.554240+00:00 0:10:01.806382 362611 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-01T21:00:50.220603+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-01T20:00:00+00:00 EmrCreateJobFlowOperator 2023-04-01T21:00:30.793568+00:00 2023-04-01T21:00:31.680979+00:00 0:00:00.887411 362609 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-01T21:00:28.211397+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-01T20:00:00+00:00 PythonOperator 2023-04-01T21:00:08.928622+00:00 2023-04-01T21:00:14.904629+00:00 0:00:05.976007 362607 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-01T21:00:06.206344+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-01T19:00:00+00:00 TriggerDagRunOperator 2023-04-01T20:11:23.627108+00:00 2023-04-01T20:11:24.118781+00:00 0:00:00.491673 362596 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-01T20:11:21.167854+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-01T19:00:00+00:00 TriggerDagRunOperator 2023-04-01T20:11:23.542578+00:00 2023-04-01T20:11:24.059231+00:00 0:00:00.516653 362595 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-01T20:11:21.167883+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-01T19:00:00+00:00 EmrJobFlowSensor 2023-04-01T20:01:03.412908+00:00 2023-04-01T20:11:05.209064+00:00 0:10:01.796156 362589 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-01T20:01:00.894655+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-01T19:00:00+00:00 EmrCreateJobFlowOperator 2023-04-01T20:00:41.100348+00:00 2023-04-01T20:00:41.972736+00:00 0:00:00.872388 362587 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-01T20:00:38.797203+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-01T19:00:00+00:00 PythonOperator 2023-04-01T20:00:20.962879+00:00 2023-04-01T20:00:24.518701+00:00 0:00:03.555822 362585 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-01T20:00:18.654734+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-01T18:00:00+00:00 TriggerDagRunOperator 2023-04-01T19:11:27.137446+00:00 2023-04-01T19:11:27.643980+00:00 0:00:00.506534 362572 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-01T19:11:24.329069+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-01T18:00:00+00:00 TriggerDagRunOperator 2023-04-01T19:11:27.121960+00:00 2023-04-01T19:11:27.611080+00:00 0:00:00.489120 362571 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-01T19:11:24.329041+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-01T18:00:00+00:00 EmrJobFlowSensor 2023-04-01T19:01:03.964068+00:00 2023-04-01T19:11:05.690821+00:00 0:10:01.726753 362568 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-01T19:01:01.774542+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-01T18:00:00+00:00 EmrCreateJobFlowOperator 2023-04-01T19:00:44.412011+00:00 2023-04-01T19:00:45.294754+00:00 0:00:00.882743 362566 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-01T19:00:39.751834+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-01T18:00:00+00:00 PythonOperator 2023-04-01T19:00:21.949528+00:00 2023-04-01T19:00:25.278068+00:00 0:00:03.328540 362564 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-01T19:00:19.734840+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-01T17:00:00+00:00 TriggerDagRunOperator 2023-04-01T18:29:12.018004+00:00 2023-04-01T18:29:12.488662+00:00 0:00:00.470658 362556 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-01T18:29:09.080047+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-01T17:00:00+00:00 TriggerDagRunOperator 2023-04-01T18:29:11.800368+00:00 2023-04-01T18:29:12.268490+00:00 0:00:00.468122 362555 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-01T18:29:09.080015+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-01T17:00:00+00:00 EmrJobFlowSensor 2023-04-01T18:00:56.341332+00:00 2023-04-01T18:10:58.288925+00:00 0:10:01.947593 362545 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-01T18:00:54.152084+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-01T17:00:00+00:00 EmrCreateJobFlowOperator 2023-04-01T18:00:36.614732+00:00 2023-04-01T18:00:37.561824+00:00 0:00:00.947092 362544 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-01T18:00:34.194440+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-01T17:00:00+00:00 PythonOperator 2023-04-01T18:00:14.354552+00:00 2023-04-01T18:00:18.394853+00:00 0:00:04.040301 362543 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-01T18:00:12.111865+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-01T16:00:00+00:00 TriggerDagRunOperator 2023-04-01T17:13:56.586771+00:00 2023-04-01T17:13:57.056661+00:00 0:00:00.469890 362534 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-01T17:13:53.732302+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-01T16:00:00+00:00 TriggerDagRunOperator 2023-04-01T17:13:56.258898+00:00 2023-04-01T17:13:56.757028+00:00 0:00:00.498130 362533 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-01T17:13:53.732331+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-01T16:00:00+00:00 EmrJobFlowSensor 2023-04-01T17:01:40.556446+00:00 2023-04-01T17:11:42.332118+00:00 0:10:01.775672 362526 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-01T17:01:38.421265+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-01T16:00:00+00:00 EmrCreateJobFlowOperator 2023-04-01T17:01:18.607767+00:00 2023-04-01T17:01:19.458255+00:00 0:00:00.850488 362524 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-01T17:01:16.400312+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-01T16:00:00+00:00 PythonOperator 2023-04-01T17:00:59.030227+00:00 2023-04-01T17:01:03.111535+00:00 0:00:04.081308 362522 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-01T17:00:56.434313+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-01T15:00:00+00:00 TriggerDagRunOperator 2023-04-01T16:24:40.586913+00:00 2023-04-01T16:24:41.120652+00:00 0:00:00.533739 362514 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-01T16:24:37.493198+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-01T15:00:00+00:00 TriggerDagRunOperator 2023-04-01T16:24:40.378323+00:00 2023-04-01T16:24:40.817509+00:00 0:00:00.439186 362513 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-01T16:24:37.493161+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-01T15:00:00+00:00 EmrJobFlowSensor 2023-04-01T16:06:39.054640+00:00 2023-04-01T16:16:40.804342+00:00 0:10:01.749702 362508 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-01T16:06:36.836177+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-01T15:00:00+00:00 EmrCreateJobFlowOperator 2023-04-01T16:06:17.164620+00:00 2023-04-01T16:06:18.062686+00:00 0:00:00.898066 362506 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-01T16:06:14.812639+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-01T15:00:00+00:00 PythonOperator 2023-04-01T16:05:57.344230+00:00 2023-04-01T16:06:01.501097+00:00 0:00:04.156867 362502 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-01T16:05:54.795798+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-01T14:00:00+00:00 TriggerDagRunOperator 2023-04-01T15:17:03.437654+00:00 2023-04-01T15:17:03.974771+00:00 0:00:00.537117 362496 airflow-worker-2.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-01T15:17:00.930684+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-01T14:00:00+00:00 TriggerDagRunOperator 2023-04-01T15:17:03.305204+00:00 2023-04-01T15:17:03.773336+00:00 0:00:00.468132 362495 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-01T15:17:00.930655+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-01T14:00:00+00:00 EmrJobFlowSensor 2023-04-01T15:06:47.900476+00:00 2023-04-01T15:16:49.768806+00:00 0:10:01.868330 362490 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-01T15:06:45.626606+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-01T14:00:00+00:00 EmrCreateJobFlowOperator 2023-04-01T15:06:26.156331+00:00 2023-04-01T15:06:26.987871+00:00 0:00:00.831540 362487 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-01T15:06:23.560201+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-01T14:00:00+00:00 PythonOperator 2023-04-01T15:06:06.381127+00:00 2023-04-01T15:06:10.151407+00:00 0:00:03.770280 362484 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-01T15:06:03.608212+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-01T13:00:00+00:00 TriggerDagRunOperator 2023-04-01T14:34:10.097914+00:00 2023-04-01T14:34:10.583962+00:00 0:00:00.486048 362478 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-01T14:34:07.323250+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-01T13:00:00+00:00 TriggerDagRunOperator 2023-04-01T14:34:09.835817+00:00 2023-04-01T14:34:10.304987+00:00 0:00:00.469170 362477 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-01T14:34:07.323221+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-01T13:00:00+00:00 EmrJobFlowSensor 2023-04-01T14:03:57.427783+00:00 2023-04-01T14:13:59.091201+00:00 0:10:01.663418 362471 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-01T14:03:55.257723+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-01T13:00:00+00:00 EmrCreateJobFlowOperator 2023-04-01T14:03:39.907396+00:00 2023-04-01T14:03:41.143917+00:00 0:00:01.236521 362469 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-01T14:03:35.221226+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-01T13:00:00+00:00 PythonOperator 2023-04-01T14:03:15.359211+00:00 2023-04-01T14:03:19.326559+00:00 0:00:03.967348 362467 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-01T14:03:13.211486+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-01T12:00:00+00:00 TriggerDagRunOperator 2023-04-01T13:33:10.789871+00:00 2023-04-01T13:33:11.412195+00:00 0:00:00.622324 362459 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-01T13:33:08.024979+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-01T12:00:00+00:00 TriggerDagRunOperator 2023-04-01T13:33:10.570215+00:00 2023-04-01T13:33:11.092598+00:00 0:00:00.522383 362458 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-01T13:33:08.024951+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-01T12:00:00+00:00 EmrJobFlowSensor 2023-04-01T13:02:02.466784+00:00 2023-04-01T13:12:04.267576+00:00 0:10:01.800792 362452 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-01T13:01:59.847650+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-01T12:00:00+00:00 EmrCreateJobFlowOperator 2023-04-01T13:01:39.969490+00:00 2023-04-01T13:01:40.818641+00:00 0:00:00.849151 362450 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-01T13:01:37.780505+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-01T12:00:00+00:00 PythonOperator 2023-04-01T13:01:18.401843+00:00 2023-04-01T13:01:22.476854+00:00 0:00:04.075011 362447 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-01T13:01:15.733652+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-01T11:00:00+00:00 TriggerDagRunOperator 2023-04-01T12:11:21.201280+00:00 2023-04-01T12:11:21.692437+00:00 0:00:00.491157 362440 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-01T12:11:18.490160+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-01T11:00:00+00:00 TriggerDagRunOperator 2023-04-01T12:11:21.153644+00:00 2023-04-01T12:11:21.632770+00:00 0:00:00.479126 362439 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-01T12:11:18.490130+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-01T11:00:00+00:00 EmrJobFlowSensor 2023-04-01T12:01:02.680614+00:00 2023-04-01T12:11:04.473138+00:00 0:10:01.792524 362433 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-01T12:01:00.292278+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-01T11:00:00+00:00 EmrCreateJobFlowOperator 2023-04-01T12:00:40.351360+00:00 2023-04-01T12:00:41.187547+00:00 0:00:00.836187 362431 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-01T12:00:38.172106+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-01T11:00:00+00:00 PythonOperator 2023-04-01T12:00:20.255989+00:00 2023-04-01T12:00:24.286101+00:00 0:00:04.030112 362429 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-01T12:00:18.150463+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-01T10:00:00+00:00 TriggerDagRunOperator 2023-04-01T11:17:59.583628+00:00 2023-04-01T11:18:00.231916+00:00 0:00:00.648288 362420 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-01T11:17:56.744702+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-01T10:00:00+00:00 TriggerDagRunOperator 2023-04-01T11:17:59.408566+00:00 2023-04-01T11:17:59.957480+00:00 0:00:00.548914 362419 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-01T11:17:56.744671+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-01T10:00:00+00:00 EmrJobFlowSensor 2023-04-01T11:06:26.909679+00:00 2023-04-01T11:16:28.809249+00:00 0:10:01.899570 362414 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-01T11:06:24.591034+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-01T10:00:00+00:00 EmrCreateJobFlowOperator 2023-04-01T11:06:06.860398+00:00 2023-04-01T11:06:07.840764+00:00 0:00:00.980366 362412 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-01T11:06:04.576023+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-01T10:00:00+00:00 PythonOperator 2023-04-01T11:05:45.497428+00:00 2023-04-01T11:05:48.824096+00:00 0:00:03.326668 362409 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-01T11:05:42.381414+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-01T09:00:00+00:00 TriggerDagRunOperator 2023-04-01T10:11:24.209595+00:00 2023-04-01T10:11:24.672889+00:00 0:00:00.463294 362403 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-01T10:11:21.706764+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-01T09:00:00+00:00 TriggerDagRunOperator 2023-04-01T10:11:24.004958+00:00 2023-04-01T10:11:24.489177+00:00 0:00:00.484219 362402 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-01T10:11:21.706734+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-01T09:00:00+00:00 EmrJobFlowSensor 2023-04-01T10:01:08.237357+00:00 2023-04-01T10:11:10.015527+00:00 0:10:01.778170 362396 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-01T10:01:05.790472+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-01T09:00:00+00:00 EmrCreateJobFlowOperator 2023-04-01T10:00:44.043097+00:00 2023-04-01T10:00:45.478609+00:00 0:00:01.435512 362394 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-01T10:00:41.714480+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-01T09:00:00+00:00 PythonOperator 2023-04-01T10:00:22.115454+00:00 2023-04-01T10:00:26.244881+00:00 0:00:04.129427 362391 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-01T10:00:19.632618+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-01T08:00:00+00:00 TriggerDagRunOperator 2023-04-01T09:18:47.029601+00:00 2023-04-01T09:18:47.528966+00:00 0:00:00.499365 362383 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-01T09:18:44.540984+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-01T08:00:00+00:00 TriggerDagRunOperator 2023-04-01T09:18:46.907858+00:00 2023-04-01T09:18:47.357933+00:00 0:00:00.450075 362382 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-01T09:18:44.541012+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-01T08:00:00+00:00 EmrJobFlowSensor 2023-04-01T09:08:26.134579+00:00 2023-04-01T09:18:27.948059+00:00 0:10:01.813480 362377 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-01T09:08:23.835225+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-01T08:00:00+00:00 EmrCreateJobFlowOperator 2023-04-01T09:08:06.239895+00:00 2023-04-01T09:08:07.231271+00:00 0:00:00.991376 362374 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-01T09:08:03.813590+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-01T08:00:00+00:00 PythonOperator 2023-04-01T09:07:44.609508+00:00 2023-04-01T09:07:48.347352+00:00 0:00:03.737844 362371 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-01T09:07:41.792861+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-01T07:00:00+00:00 TriggerDagRunOperator 2023-04-01T08:28:49.417297+00:00 2023-04-01T08:28:49.865329+00:00 0:00:00.448032 362364 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-01T08:28:46.677167+00:00 2 default_pool