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 check_cluster_status 2023-02-21T09:00:00+00:00 EmrJobFlowSensor 2023-02-21T10:01:06.535570+00:00 2023-02-21T10:10:08.268035+00:00 0:09:01.732465 343735 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-21T10:01:04.064490+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-21T09:00:00+00:00 EmrCreateJobFlowOperator 2023-02-21T10:00:46.428674+00:00 2023-02-21T10:00:47.269996+00:00 0:00:00.841322 343733 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-21T10:00:44.045878+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-21T09:00:00+00:00 PythonOperator 2023-02-21T10:00:24.135401+00:00 2023-02-21T10:00:28.225672+00:00 0:00:04.090271 343731 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-21T10:00:21.988826+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-21T08:00:00+00:00 TriggerDagRunOperator 2023-02-21T09:10:58.177163+00:00 2023-02-21T09:10:58.650728+00:00 0:00:00.473565 343723 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-21T09:10:55.007159+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-21T08:00:00+00:00 TriggerDagRunOperator 2023-02-21T09:10:57.391722+00:00 2023-02-21T09:10:58.056706+00:00 0:00:00.664984 343722 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-21T09:10:55.007126+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-21T08:00:00+00:00 EmrJobFlowSensor 2023-02-21T09:00:50.856040+00:00 2023-02-21T09:10:52.773813+00:00 0:10:01.917773 343716 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-21T09:00:48.206315+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-21T08:00:00+00:00 EmrCreateJobFlowOperator 2023-02-21T09:00:28.689146+00:00 2023-02-21T09:00:29.624629+00:00 0:00:00.935483 343713 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-21T09:00:26.199109+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-21T08:00:00+00:00 PythonOperator 2023-02-21T09:00:06.947370+00:00 2023-02-21T09:00:10.076002+00:00 0:00:03.128632 343712 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-21T09:00:04.123100+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-21T07:00:00+00:00 TriggerDagRunOperator 2023-02-21T08:38:36.918106+00:00 2023-02-21T08:38:37.439072+00:00 0:00:00.520966 343705 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-21T08:38:34.535506+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-21T07:00:00+00:00 TriggerDagRunOperator 2023-02-21T08:38:36.908521+00:00 2023-02-21T08:38:37.403682+00:00 0:00:00.495161 343704 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-21T08:38:34.535477+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-21T07:00:00+00:00 EmrJobFlowSensor 2023-02-21T08:08:12.377280+00:00 2023-02-21T08:18:14.256400+00:00 0:10:01.879120 343701 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-21T08:08:09.995954+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-21T07:00:00+00:00 EmrCreateJobFlowOperator 2023-02-21T08:07:56.582717+00:00 2023-02-21T08:07:57.431818+00:00 0:00:00.849101 343698 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-21T08:07:49.985520+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-21T07:00:00+00:00 PythonOperator 2023-02-21T08:07:30.439670+00:00 2023-02-21T08:07:36.331891+00:00 0:00:05.892221 343695 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-21T08:07:26.022302+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-21T06:00:00+00:00 TriggerDagRunOperator 2023-02-21T07:20:00.166761+00:00 2023-02-21T07:20:00.756374+00:00 0:00:00.589613 343686 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-21T07:19:57.416519+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-21T06:00:00+00:00 TriggerDagRunOperator 2023-02-21T07:19:59.954200+00:00 2023-02-21T07:20:00.704806+00:00 0:00:00.750606 343685 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-21T07:19:57.416489+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-21T06:00:00+00:00 EmrJobFlowSensor 2023-02-21T07:09:43.022143+00:00 2023-02-21T07:19:44.776116+00:00 0:10:01.753973 343681 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-21T07:09:40.684404+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-21T06:00:00+00:00 EmrCreateJobFlowOperator 2023-02-21T07:09:23.825311+00:00 2023-02-21T07:09:24.637069+00:00 0:00:00.811758 343679 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-21T07:09:20.687562+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-21T06:00:00+00:00 PythonOperator 2023-02-21T07:09:01.064623+00:00 2023-02-21T07:09:04.027850+00:00 0:00:02.963227 343675 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-21T07:08:58.647048+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-21T05:00:00+00:00 TriggerDagRunOperator 2023-02-21T06:19:13.493690+00:00 2023-02-21T06:19:13.985738+00:00 0:00:00.492048 343666 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-21T06:19:10.690225+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-21T05:00:00+00:00 TriggerDagRunOperator 2023-02-21T06:19:13.333789+00:00 2023-02-21T06:19:13.891063+00:00 0:00:00.557274 343665 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-21T06:19:10.690256+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-21T05:00:00+00:00 EmrJobFlowSensor 2023-02-21T06:08:59.751682+00:00 2023-02-21T06:19:01.601152+00:00 0:10:01.849470 343661 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-21T06:08:57.407425+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-21T05:00:00+00:00 EmrCreateJobFlowOperator 2023-02-21T06:08:40.417613+00:00 2023-02-21T06:08:41.453747+00:00 0:00:01.036134 343659 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-21T06:08:37.386349+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-21T05:00:00+00:00 PythonOperator 2023-02-21T06:08:17.750168+00:00 2023-02-21T06:08:21.716040+00:00 0:00:03.965872 343655 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-21T06:08:15.363488+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-21T04:00:00+00:00 TriggerDagRunOperator 2023-02-21T05:35:16.963110+00:00 2023-02-21T05:35:17.489079+00:00 0:00:00.525969 343649 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-21T05:35:14.047915+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-21T04:00:00+00:00 TriggerDagRunOperator 2023-02-21T05:35:16.885352+00:00 2023-02-21T05:35:17.373422+00:00 0:00:00.488070 343648 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-21T05:35:14.047886+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-21T04:00:00+00:00 EmrJobFlowSensor 2023-02-21T05:24:27.168277+00:00 2023-02-21T05:34:28.960747+00:00 0:10:01.792470 343644 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-21T05:24:24.577708+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-21T04:00:00+00:00 EmrCreateJobFlowOperator 2023-02-21T05:24:04.975394+00:00 2023-02-21T05:24:05.787757+00:00 0:00:00.812363 343641 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-21T05:24:02.623516+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-21T04:00:00+00:00 PythonOperator 2023-02-21T05:23:46.962453+00:00 2023-02-21T05:23:50.257309+00:00 0:00:03.294856 343638 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-21T05:23:42.541022+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-21T03:00:00+00:00 TriggerDagRunOperator 2023-02-21T04:17:56.765763+00:00 2023-02-21T04:17:57.253373+00:00 0:00:00.487610 343628 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-21T04:17:53.915143+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-21T03:00:00+00:00 TriggerDagRunOperator 2023-02-21T04:17:56.667205+00:00 2023-02-21T04:17:57.166273+00:00 0:00:00.499068 343627 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-21T04:17:53.915095+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-21T03:00:00+00:00 EmrJobFlowSensor 2023-02-21T04:07:31.275045+00:00 2023-02-21T04:17:32.992896+00:00 0:10:01.717851 343623 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-21T04:07:28.800332+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-21T03:00:00+00:00 EmrCreateJobFlowOperator 2023-02-21T04:07:09.056393+00:00 2023-02-21T04:07:10.296028+00:00 0:00:01.239635 343620 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-21T04:07:06.687609+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-21T03:00:00+00:00 PythonOperator 2023-02-21T04:06:47.315945+00:00 2023-02-21T04:06:52.852529+00:00 0:00:05.536584 343617 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-21T04:06:44.687951+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-21T02:00:00+00:00 TriggerDagRunOperator 2023-02-21T03:18:45.931796+00:00 2023-02-21T03:18:46.477141+00:00 0:00:00.545345 343608 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-21T03:18:43.334642+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-21T02:00:00+00:00 TriggerDagRunOperator 2023-02-21T03:18:45.701586+00:00 2023-02-21T03:18:46.231006+00:00 0:00:00.529420 343607 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-21T03:18:43.334670+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-21T02:00:00+00:00 EmrJobFlowSensor 2023-02-21T03:08:34.035073+00:00 2023-02-21T03:18:35.771060+00:00 0:10:01.735987 343604 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-21T03:08:31.810433+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-21T02:00:00+00:00 EmrCreateJobFlowOperator 2023-02-21T03:08:12.797957+00:00 2023-02-21T03:08:13.631722+00:00 0:00:00.833765 343601 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-21T03:08:09.798475+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-21T02:00:00+00:00 PythonOperator 2023-02-21T03:00:16.544629+00:00 2023-02-21T03:00:20.490737+00:00 0:00:03.946108 343596 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-21T03:00:14.300830+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-21T01:00:00+00:00 TriggerDagRunOperator 2023-02-21T02:17:49.580151+00:00 2023-02-21T02:17:50.127287+00:00 0:00:00.547136 343587 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-21T02:17:46.840620+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-21T01:00:00+00:00 TriggerDagRunOperator 2023-02-21T02:17:49.353769+00:00 2023-02-21T02:17:49.823105+00:00 0:00:00.469336 343586 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-21T02:17:46.840590+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-21T01:00:00+00:00 EmrJobFlowSensor 2023-02-21T02:07:41.813739+00:00 2023-02-21T02:17:44.019504+00:00 0:10:02.205765 343581 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-21T02:07:39.539260+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-21T01:00:00+00:00 EmrCreateJobFlowOperator 2023-02-21T02:07:19.781270+00:00 2023-02-21T02:07:20.749163+00:00 0:00:00.967893 343578 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-21T02:07:17.477796+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-21T01:00:00+00:00 PythonOperator 2023-02-21T02:07:00.505402+00:00 2023-02-21T02:07:04.409091+00:00 0:00:03.903689 343575 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-21T02:06:57.455631+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-21T00:00:00+00:00 TriggerDagRunOperator 2023-02-21T01:36:24.066007+00:00 2023-02-21T01:36:24.979793+00:00 0:00:00.913786 343564 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-21T01:36:20.132853+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-21T00:00:00+00:00 TriggerDagRunOperator 2023-02-21T01:36:23.181297+00:00 2023-02-21T01:36:23.686546+00:00 0:00:00.505249 343563 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-21T01:36:20.132899+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-21T00:00:00+00:00 EmrJobFlowSensor 2023-02-21T01:17:19.104189+00:00 2023-02-21T01:27:20.875062+00:00 0:10:01.770873 343555 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-21T01:17:16.601980+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-21T00:00:00+00:00 EmrCreateJobFlowOperator 2023-02-21T01:16:57.059572+00:00 2023-02-21T01:16:57.913339+00:00 0:00:00.853767 343551 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-21T01:16:54.509844+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-20T23:00:00+00:00 TriggerDagRunOperator 2023-02-21T01:16:41.598110+00:00 2023-02-21T01:16:43.495369+00:00 0:00:01.897259 343548 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-21T01:16:33.939117+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-20T23:00:00+00:00 TriggerDagRunOperator 2023-02-21T01:16:41.096695+00:00 2023-02-21T01:16:42.910376+00:00 0:00:01.813681 343547 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-21T01:16:33.939158+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-21T00:00:00+00:00 PythonOperator 2023-02-21T01:16:37.224983+00:00 2023-02-21T01:16:40.378225+00:00 0:00:03.153242 343546 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-21T01:16:33.939175+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-20T23:00:00+00:00 EmrJobFlowSensor 2023-02-21T00:02:52.895264+00:00 2023-02-21T00:12:54.736783+00:00 0:10:01.841519 343540 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-21T00:02:50.609096+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-20T23:00:00+00:00 EmrCreateJobFlowOperator 2023-02-21T00:02:31.017881+00:00 2023-02-21T00:02:31.933615+00:00 0:00:00.915734 343538 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-21T00:02:28.567266+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-20T23:00:00+00:00 PythonOperator 2023-02-21T00:02:11.137428+00:00 2023-02-21T00:02:15.135452+00:00 0:00:03.998024 343536 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-21T00:02:08.548034+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-20T22:00:00+00:00 TriggerDagRunOperator 2023-02-20T23:17:35.386699+00:00 2023-02-20T23:17:35.902174+00:00 0:00:00.515475 343522 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-20T23:17:32.271624+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-20T22:00:00+00:00 TriggerDagRunOperator 2023-02-20T23:17:35.193208+00:00 2023-02-20T23:17:35.664196+00:00 0:00:00.470988 343521 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-20T23:17:32.271676+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-20T22:00:00+00:00 EmrJobFlowSensor 2023-02-20T23:05:02.209075+00:00 2023-02-20T23:15:04.063337+00:00 0:10:01.854262 343514 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-20T23:04:59.470855+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-20T22:00:00+00:00 EmrCreateJobFlowOperator 2023-02-20T23:04:39.654813+00:00 2023-02-20T23:04:40.481117+00:00 0:00:00.826304 343511 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-20T23:04:37.450561+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-20T22:00:00+00:00 PythonOperator 2023-02-20T23:04:20.260196+00:00 2023-02-20T23:04:26.243757+00:00 0:00:05.983561 343508 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-20T23:04:17.426229+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-20T21:00:00+00:00 TriggerDagRunOperator 2023-02-20T22:11:28.902738+00:00 2023-02-20T22:11:29.418264+00:00 0:00:00.515526 343494 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-20T22:11:26.530762+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-20T21:00:00+00:00 TriggerDagRunOperator 2023-02-20T22:11:28.719468+00:00 2023-02-20T22:11:29.179463+00:00 0:00:00.459995 343493 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-20T22:11:26.530799+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-20T21:00:00+00:00 EmrJobFlowSensor 2023-02-20T22:01:01.409336+00:00 2023-02-20T22:11:03.180677+00:00 0:10:01.771341 343486 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-20T22:00:58.996212+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-20T21:00:00+00:00 EmrCreateJobFlowOperator 2023-02-20T22:00:41.795962+00:00 2023-02-20T22:00:43.056562+00:00 0:00:01.260600 343484 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-20T22:00:38.909590+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-20T21:00:00+00:00 PythonOperator 2023-02-20T22:00:19.888882+00:00 2023-02-20T22:00:23.041630+00:00 0:00:03.152748 343482 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-20T22:00:16.706414+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-20T20:00:00+00:00 TriggerDagRunOperator 2023-02-20T21:11:29.501353+00:00 2023-02-20T21:11:30.058695+00:00 0:00:00.557342 343469 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-20T21:11:26.801307+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-20T20:00:00+00:00 TriggerDagRunOperator 2023-02-20T21:11:29.215107+00:00 2023-02-20T21:11:29.666193+00:00 0:00:00.451086 343468 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-20T21:11:26.801277+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-20T20:00:00+00:00 EmrJobFlowSensor 2023-02-20T21:01:18.134367+00:00 2023-02-20T21:11:19.885602+00:00 0:10:01.751235 343461 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-20T21:01:15.847807+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-20T20:00:00+00:00 EmrCreateJobFlowOperator 2023-02-20T21:00:56.544031+00:00 2023-02-20T21:00:57.390728+00:00 0:00:00.846697 343459 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-20T21:00:53.834130+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-20T20:00:00+00:00 PythonOperator 2023-02-20T21:00:36.240598+00:00 2023-02-20T21:00:40.037812+00:00 0:00:03.797214 343457 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-20T21:00:33.805208+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-20T19:00:00+00:00 TriggerDagRunOperator 2023-02-20T20:11:40.848871+00:00 2023-02-20T20:11:41.382028+00:00 0:00:00.533157 343443 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-20T20:11:38.408693+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-20T19:00:00+00:00 TriggerDagRunOperator 2023-02-20T20:11:40.828759+00:00 2023-02-20T20:11:41.432483+00:00 0:00:00.603724 343442 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-20T20:11:38.408736+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-20T19:00:00+00:00 EmrJobFlowSensor 2023-02-20T20:01:16.843347+00:00 2023-02-20T20:11:18.593923+00:00 0:10:01.750576 343436 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-20T20:01:14.241445+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-20T19:00:00+00:00 EmrCreateJobFlowOperator 2023-02-20T20:00:55.728245+00:00 2023-02-20T20:00:57.031204+00:00 0:00:01.302959 343434 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-20T20:00:52.188348+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-20T19:00:00+00:00 PythonOperator 2023-02-20T20:00:34.624127+00:00 2023-02-20T20:00:38.452943+00:00 0:00:03.828816 343432 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-20T20:00:32.214396+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-20T18:00:00+00:00 TriggerDagRunOperator 2023-02-20T19:13:03.539546+00:00 2023-02-20T19:13:04.069817+00:00 0:00:00.530271 343417 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-20T19:13:00.612219+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-20T18:00:00+00:00 TriggerDagRunOperator 2023-02-20T19:13:03.281773+00:00 2023-02-20T19:13:03.768313+00:00 0:00:00.486540 343416 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-20T19:13:00.612188+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-20T18:00:00+00:00 EmrJobFlowSensor 2023-02-20T19:02:55.766000+00:00 2023-02-20T19:12:57.942871+00:00 0:10:02.176871 343410 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-20T19:02:52.302188+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-20T18:00:00+00:00 EmrCreateJobFlowOperator 2023-02-20T19:02:32.679058+00:00 2023-02-20T19:02:33.561352+00:00 0:00:00.882294 343408 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-20T19:02:30.269438+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-20T18:00:00+00:00 PythonOperator 2023-02-20T19:02:14.328625+00:00 2023-02-20T19:02:18.542401+00:00 0:00:04.213776 343406 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-20T19:02:10.253559+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-20T17:00:00+00:00 TriggerDagRunOperator 2023-02-20T18:14:19.236419+00:00 2023-02-20T18:14:19.744377+00:00 0:00:00.507958 343389 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-20T18:14:16.290498+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-20T17:00:00+00:00 TriggerDagRunOperator 2023-02-20T18:14:19.124220+00:00 2023-02-20T18:14:19.870687+00:00 0:00:00.746467 343388 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-20T18:14:16.290531+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-20T17:00:00+00:00 EmrJobFlowSensor 2023-02-20T18:01:03.591487+00:00 2023-02-20T18:11:05.484310+00:00 0:10:01.892823 343386 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-20T18:01:00.806259+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-20T17:00:00+00:00 EmrCreateJobFlowOperator 2023-02-20T18:00:43.373755+00:00 2023-02-20T18:00:44.412440+00:00 0:00:01.038685 343384 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-20T18:00:40.649194+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-20T17:00:00+00:00 PythonOperator 2023-02-20T18:00:21.088902+00:00 2023-02-20T18:00:24.103242+00:00 0:00:03.014340 343382 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-20T18:00:18.630572+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-20T16:00:00+00:00 TriggerDagRunOperator 2023-02-20T17:11:14.158988+00:00 2023-02-20T17:11:14.880079+00:00 0:00:00.721091 343368 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-20T17:11:11.714196+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-20T16:00:00+00:00 TriggerDagRunOperator 2023-02-20T17:11:13.900313+00:00 2023-02-20T17:11:14.549724+00:00 0:00:00.649411 343367 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-20T17:11:11.714227+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-20T16:00:00+00:00 EmrJobFlowSensor 2023-02-20T17:01:02.566070+00:00 2023-02-20T17:11:04.427796+00:00 0:10:01.861726 343361 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-20T17:01:00.196283+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-20T16:00:00+00:00 EmrCreateJobFlowOperator 2023-02-20T17:00:40.345714+00:00 2023-02-20T17:00:41.138431+00:00 0:00:00.792717 343359 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-20T17:00:38.034824+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-20T16:00:00+00:00 PythonOperator 2023-02-20T17:00:20.185237+00:00 2023-02-20T17:00:24.120976+00:00 0:00:03.935739 343357 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-20T17:00:17.937940+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-20T15:00:00+00:00 TriggerDagRunOperator 2023-02-20T16:18:07.473238+00:00 2023-02-20T16:18:07.957605+00:00 0:00:00.484367 343344 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-20T16:18:04.825062+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-20T15:00:00+00:00 TriggerDagRunOperator 2023-02-20T16:18:07.344795+00:00 2023-02-20T16:18:07.835757+00:00 0:00:00.490962 343343 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-20T16:18:04.825033+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-20T15:00:00+00:00 EmrJobFlowSensor 2023-02-20T16:07:54.476942+00:00 2023-02-20T16:17:56.277197+00:00 0:10:01.800255 343339 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-20T16:07:52.059545+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-20T15:00:00+00:00 EmrCreateJobFlowOperator 2023-02-20T16:07:32.350902+00:00 2023-02-20T16:07:33.155945+00:00 0:00:00.805043 343336 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-20T16:07:30.067965+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-20T15:00:00+00:00 PythonOperator 2023-02-20T16:07:12.240258+00:00 2023-02-20T16:07:16.199976+00:00 0:00:03.959718 343333 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-20T16:07:10.009658+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-20T14:00:00+00:00 TriggerDagRunOperator 2023-02-20T15:17:24.475378+00:00 2023-02-20T15:17:24.917764+00:00 0:00:00.442386 343319 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-20T15:17:21.403343+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-20T14:00:00+00:00 TriggerDagRunOperator 2023-02-20T15:17:23.889326+00:00 2023-02-20T15:17:24.390484+00:00 0:00:00.501158 343318 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-20T15:17:21.403377+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-20T14:00:00+00:00 EmrJobFlowSensor 2023-02-20T15:00:57.804469+00:00 2023-02-20T15:10:59.499123+00:00 0:10:01.694654 343314 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-20T15:00:55.428808+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-20T14:00:00+00:00 EmrCreateJobFlowOperator 2023-02-20T15:00:38.000864+00:00 2023-02-20T15:00:38.886872+00:00 0:00:00.886008 343312 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-20T15:00:35.404402+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-20T14:00:00+00:00 PythonOperator 2023-02-20T15:00:16.251244+00:00 2023-02-20T15:00:19.231302+00:00 0:00:02.980058 343310 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-20T15:00:13.394505+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-20T13:00:00+00:00 TriggerDagRunOperator 2023-02-20T14:11:28.594583+00:00 2023-02-20T14:11:29.130504+00:00 0:00:00.535921 343295 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-20T14:11:26.056593+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-20T13:00:00+00:00 TriggerDagRunOperator 2023-02-20T14:11:28.521239+00:00 2023-02-20T14:11:28.998885+00:00 0:00:00.477646 343294 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-20T14:11:26.056555+00:00 2 default_pool