Logs


Id Dttm Dag Id Task Id Event Execution Date Owner Extra
2266743 07-07T08:05:46.133057+00:00 exchange-trade-summary_v1_v002 graph 06-10T00:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-10 00:00:00+00:00')]
2266739 07-07T08:05:45.053597+00:00 exchange-trade-summary_v1_v002 graph 06-13T10:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-13 10:00:00+00:00'), ('run_id', 'scheduled__2024-06-13T10:00:00+00:00')]
2266738 07-07T08:05:44.578226+00:00 exchange-trade-summary_v1_v002 graph 06-09T02:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-09 02:00:00+00:00'), ('run_id', 'scheduled__2024-06-09T02:00:00+00:00')]
2266716 07-07T08:05:34.715112+00:00 exchange-trade-summary_v1_v002 graph 06-20T00:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-20 00:00:00+00:00')]
2266712 07-07T08:05:30.086618+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps xcom 02-27T09:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-02-27T09:00:00+00:00'), ('task_id', 'create_cluster_and_add_emr_steps')]
2266711 07-07T08:05:28.950458+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps xcom 02-26T16:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-02-26T16:00:00+00:00'), ('task_id', 'create_cluster_and_add_emr_steps')]
2266709 07-07T08:05:25.388248+00:00 exchange-trade-summary_v1_v002 create_emr_steps xcom 02-26T15:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-02-26T15:00:00+00:00'), ('task_id', 'create_emr_steps')]
2266697 07-07T08:05:20.387561+00:00 exchange-trade-summary_v1_v002 graph 2023-11-03T15:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2023-11-03 15:00:00+00:00')]
2266686 07-07T08:05:17.100442+00:00 exchange-trade-summary_v1_v002 graph 02-24T00:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-02-24T00:00:00+00:00'), ('root', 'create_emr_steps')]
2266684 07-07T08:05:16.768208+00:00 exchange-trade-summary_v1_v002 graph 06-13T06:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-13 06:00:00+00:00')]
2266679 07-07T08:05:14.374896+00:00 exchange-trade-summary_v1_v002 graph 07-02T19:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-07-02 19:00:00+00:00')]
2266661 07-07T08:05:07.616540+00:00 exchange-trade-summary_v1_v002 graph 02-24T03:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-02-24T03:00:00+00:00'), ('root', 'create_emr_steps')]
2266652 07-07T08:05:04.612412+00:00 exchange-trade-summary_v1_v002 create_emr_steps log 02-23T11:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-02-23T11:00:00+00:00'), ('task_id', 'create_emr_steps')]
2266645 07-07T08:05:00.186064+00:00 exchange-trade-summary_v1_v002 graph 06-07T17:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-07 17:00:00+00:00')]
2266618 07-07T08:04:41.790895+00:00 exchange-trade-summary_v1_v002 graph 06-18T04:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-18 04:00:00+00:00')]
2266614 07-07T08:04:40.823243+00:00 exchange-trade-summary_v1_v002 graph 06-20T09:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-20 09:00:00+00:00'), ('run_id', 'scheduled__2024-06-20T09:00:00+00:00')]
2266604 07-07T08:04:36.568273+00:00 exchange-trade-summary_v1_v002 graph 2023-11-10T03:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2023-11-10T03:00:00+00:00'), ('root', 'check_cluster_status')]
2266596 07-07T08:04:32.410749+00:00 exchange-trade-summary_v1_v002 graph 06-08T15:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-08 15:00:00+00:00'), ('run_id', 'scheduled__2024-06-08T15:00:00+00:00')]
2266595 07-07T08:04:31.238977+00:00 exchange-trade-summary_v1_v002 graph 06-08T07:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-08 07:00:00+00:00')]
2266593 07-07T08:04:29.965669+00:00 exchange-trade-summary_v1_v002 graph 02-23T21:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-02-23 21:00:00+00:00')]
2266590 07-07T08:04:29.301892+00:00 exchange-trade-summary_v1_v002 graph 06-05T17:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-05 17:00:00+00:00')]
2266580 07-07T08:04:24.300682+00:00 exchange-trade-summary_v1_v002 graph 06-18T21:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-18 21:00:00+00:00'), ('run_id', 'scheduled__2024-06-18T21:00:00+00:00')]
2266577 07-07T08:04:23.464774+00:00 exchange-trade-summary_v1_v002 graph 06-26T23:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-26T23:00:00+00:00')]
2266576 07-07T08:04:22.199765+00:00 exchange-trade-summary_v1_v002 graph 06-21T21:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-21 21:00:00+00:00')]
2266573 07-07T08:04:19.666483+00:00 exchange-trade-summary_v1_v002 graph 2023-11-02T22:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2023-11-02 22:00:00+00:00')]
2266572 07-07T08:04:18.793912+00:00 exchange-trade-summary_v1_v002 graph 2023-11-10T10:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2023-11-10T10:00:00+00:00'), ('root', 'check_cluster_status')]
2266567 07-07T08:04:16.884279+00:00 exchange-trade-summary_v1_v002 check_cluster_status task 2023-11-10T06:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2023-11-10T06:00:00+00:00'), ('task_id', 'check_cluster_status')]
2266556 07-07T08:04:12.494044+00:00 exchange-trade-summary_v1_v002 graph 07-04T12:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-07-04 12:00:00+00:00'), ('run_id', 'scheduled__2024-07-04T12:00:00+00:00')]
2266547 07-07T08:04:09.804109+00:00 exchange-trade-summary_v1_v002 graph 07-03T23:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-07-03 23:00:00+00:00'), ('run_id', 'scheduled__2024-07-03T23:00:00+00:00')]
2266539 07-07T08:04:01.386280+00:00 exchange-trade-summary_v1_v002 create_emr_steps log 02-23T20:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-02-23T20:00:00+00:00'), ('task_id', 'create_emr_steps')]
2266531 07-07T08:03:58.343710+00:00 exchange-trade-summary_v1_v002 graph 06-23T07:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-23 07:00:00+00:00')]
2266522 07-07T08:03:54.407564+00:00 exchange-trade-summary_v1_v002 graph 2023-11-05T13:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2023-11-05 13:00:00+00:00'), ('run_id', 'scheduled__2023-11-05T13:00:00+00:00')]
2266519 07-07T08:03:53.691387+00:00 exchange-trade-summary_v1_v002 graph 06-08T15:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-08 15:00:00+00:00')]
2266509 07-07T08:03:49.643674+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps log 2023-11-10T08:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2023-11-10T08:00:00+00:00'), ('task_id', 'create_cluster_and_add_emr_steps')]
2266488 07-07T08:03:42.665375+00:00 exchange-trade-summary_v1_v002 graph 2023-11-05T22:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2023-11-05 22:00:00+00:00'), ('run_id', 'scheduled__2023-11-05T22:00:00+00:00')]
2266483 07-07T08:03:40.620963+00:00 exchange-trade-summary_v1_v002 check_cluster_status rendered 02-24T13:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-02-24T13:00:00+00:00'), ('task_id', 'check_cluster_status')]
2266478 07-07T08:03:37.908554+00:00 exchange-trade-summary_v1_v002 create_emr_steps rendered 02-28T15:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-02-28T15:00:00+00:00'), ('task_id', 'create_emr_steps')]
2266477 07-07T08:03:37.774464+00:00 exchange-trade-summary_v1_v002 graph 06-23T21:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-23 21:00:00+00:00')]
2266467 07-07T08:03:33.873312+00:00 exchange-trade-summary_v1_v002 graph 06-05T18:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-05 18:00:00+00:00')]
2266460 07-07T08:03:30.759786+00:00 exchange-trade-summary_v1_v002 check_cluster_status xcom 03-25T03:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-03-25T03:00:00+00:00'), ('task_id', 'check_cluster_status')]
2266456 07-07T08:03:27.834954+00:00 exchange-trade-summary_v1_v002 graph 06-12T13:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-12 13:00:00+00:00')]
2266454 07-07T08:03:26.994247+00:00 exchange-trade-summary_v1_v002 graph 06-12T06:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-12 06:00:00+00:00')]
2266453 07-07T08:03:25.727379+00:00 exchange-trade-summary_v1_v002 graph 06-13T11:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-13 11:00:00+00:00')]
2266439 07-07T08:03:17.351668+00:00 exchange-trade-summary_v1_v002 check_cluster_status rendered 02-27T04:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-02-27T04:00:00+00:00'), ('task_id', 'check_cluster_status')]
2266433 07-07T08:03:14.604594+00:00 exchange-trade-summary_v1_v002 graph 06-10T19:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-10 19:00:00+00:00')]
2266429 07-07T08:03:13.118286+00:00 exchange-trade-summary_v1_v002 graph 06-10T20:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-10 20:00:00+00:00')]
2266422 07-07T08:03:10.121149+00:00 exchange-trade-summary_v1_v002 graph 2023-11-05T18:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2023-11-05 18:00:00+00:00')]
2266414 07-07T08:03:07.881751+00:00 exchange-trade-summary_v1_v002 graph 06-19T04:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-19 04:00:00+00:00'), ('run_id', 'scheduled__2024-06-19T04:00:00+00:00')]
2266397 07-07T08:02:58.876344+00:00 exchange-trade-summary_v1_v002 graph 2023-11-09T14:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2023-11-09 14:00:00+00:00')]
2266382 07-07T08:02:54.531778+00:00 exchange-trade-summary_v1_v002 create_emr_steps xcom 03-26T03:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-03-26T03:00:00+00:00'), ('task_id', 'create_emr_steps')]
2266372 07-07T08:02:50.145886+00:00 exchange-trade-summary_v1_v002 check_cluster_status xcom 02-26T09:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-02-26T09:00:00+00:00'), ('task_id', 'check_cluster_status')]
2266362 07-07T08:02:45.815614+00:00 exchange-trade-summary_v1_v002 graph 06-27T04:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-27T04:00:00+00:00')]
2266352 07-07T08:02:40.392201+00:00 exchange-trade-summary_v1_v002 check_cluster_status xcom 02-26T19:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-02-26T19:00:00+00:00'), ('task_id', 'check_cluster_status')]
2266348 07-07T08:02:37.782490+00:00 exchange-trade-summary_v1_v002 graph 06-29T11:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-29T11:00:00+00:00')]
2266347 07-07T08:02:37.418197+00:00 exchange-trade-summary_v1_v002 graph 02-27T18:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-02-27T18:00:00+00:00')]
2266340 07-07T08:02:30.177562+00:00 exchange-trade-summary_v1_v002 create_emr_steps rendered 02-27T04:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-02-27T04:00:00+00:00'), ('task_id', 'create_emr_steps')]
2266330 07-07T08:02:23.251250+00:00 exchange-trade-summary_v1_v002 graph 2023-11-09T16:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2023-11-09T16:00:00+00:00'), ('root', 'create_emr_steps')]
2266328 07-07T08:02:22.577720+00:00 exchange-trade-summary_v1_v002 check_cluster_status log 2023-11-09T15:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2023-11-09T15:00:00+00:00'), ('task_id', 'check_cluster_status')]
2266326 07-07T08:02:22.182875+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps xcom 02-28T06:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-02-28T06:00:00+00:00'), ('task_id', 'create_cluster_and_add_emr_steps')]
2266325 07-07T08:02:21.725006+00:00 exchange-trade-summary_v1_v002 check_cluster_status log 2023-11-09T16:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2023-11-09T16:00:00+00:00'), ('task_id', 'check_cluster_status')]
2266318 07-07T08:02:17.671516+00:00 exchange-trade-summary_v1_v002 create_emr_steps rendered 02-28T17:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-02-28T17:00:00+00:00'), ('task_id', 'create_emr_steps')]
2266300 07-07T08:02:05.639114+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps rendered 03-25T15:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-03-25T15:00:00+00:00'), ('task_id', 'create_cluster_and_add_emr_steps')]
2266295 07-07T08:02:03.568940+00:00 exchange-trade-summary_v1_v002 check_cluster_status rendered 02-24T18:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-02-24T18:00:00+00:00'), ('task_id', 'check_cluster_status')]
2266289 07-07T08:02:01.774864+00:00 exchange-trade-summary_v1_v002 graph 02-28T20:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-02-28T20:00:00+00:00')]
2266288 07-07T08:02:01.675599+00:00 exchange-trade-summary_v1_v002 check_cluster_status log 2023-11-10T01:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2023-11-10T01:00:00+00:00'), ('task_id', 'check_cluster_status')]
2266282 07-07T08:01:59.287507+00:00 exchange-trade-summary_v1_v002 graph 2023-11-09T22:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2023-11-09T22:00:00+00:00'), ('root', 'create_emr_steps')]
2266274 07-07T08:01:56.467806+00:00 exchange-trade-summary_v1_v002 graph 02-26T08:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-02-26T08:00:00+00:00')]
2266271 07-07T08:01:55.120453+00:00 exchange-trade-summary_v1_v002 create_emr_steps rendered 03-25T19:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-03-25T19:00:00+00:00'), ('task_id', 'create_emr_steps')]
2266242 07-07T08:01:41.539140+00:00 exchange-trade-summary_v1_v002 graph 2023-11-09T19:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2023-11-09 19:00:00+00:00')]
2266238 07-07T08:01:40.711484+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps log 2023-11-09T15:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2023-11-09T15:00:00+00:00'), ('task_id', 'create_cluster_and_add_emr_steps')]
2266237 07-07T08:01:40.645457+00:00 exchange-trade-summary_v1_v002 check_cluster_status rendered 03-26T05:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-03-26T05:00:00+00:00'), ('task_id', 'check_cluster_status')]
2266230 07-07T08:01:38.385585+00:00 exchange-trade-summary_v1_v002 create_emr_steps rendered 02-28T20:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-02-28T20:00:00+00:00'), ('task_id', 'create_emr_steps')]
2266216 07-07T08:01:32.519829+00:00 exchange-trade-summary_v1_v002 check_cluster_status task 2023-11-09T15:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2023-11-09T15:00:00+00:00'), ('task_id', 'check_cluster_status')]
2266196 07-07T08:01:23.936738+00:00 exchange-trade-summary_v1_v002 graph 02-27T03:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-02-27T03:00:00+00:00')]
2266180 07-07T08:01:14.891017+00:00 exchange-trade-summary_v1_v002 graph 07-01T13:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-07-01T13:00:00+00:00')]
2266137 07-07T08:00:54.524277+00:00 exchange-trade-summary_v1_v002 create_emr_steps xcom 02-28T11:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-02-28T11:00:00+00:00'), ('task_id', 'create_emr_steps')]
2266136 07-07T08:00:53.878641+00:00 exchange-trade-summary_v1_v002 check_cluster_status cli_run 07-07T07:00:00+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'check_cluster_status', '2024-07-07T07:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
2266135 07-07T08:00:53.843919+00:00 exchange-trade-summary_v1_v002 check_cluster_status running 07-07T07:00:00+00:00 data.engineers@viooh.com
2266134 07-07T08:00:53.161259+00:00 exchange-trade-summary_v1_v002 check_cluster_status cli_run 07-07T07:00:00+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'check_cluster_status', '2024-07-07T07:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
2266124 07-07T08:00:45.294341+00:00 exchange-trade-summary_v1_v002 check_cluster_status xcom 03-24T21:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-03-24T21:00:00+00:00'), ('task_id', 'check_cluster_status')]
2266118 07-07T08:00:40.520004+00:00 exchange-trade-summary_v1_v002 create_emr_steps xcom 03-25T03:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-03-25T03:00:00+00:00'), ('task_id', 'create_emr_steps')]
2266115 07-07T08:00:37.513688+00:00 exchange-trade-summary_v1_v002 check_cluster_status xcom 02-24T18:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-02-24T18:00:00+00:00'), ('task_id', 'check_cluster_status')]
2266113 07-07T08:00:36.879844+00:00 exchange-trade-summary_v1_v002 graph 06-26T07:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-26T07:00:00+00:00')]
2266106 07-07T08:00:30.987070+00:00 exchange-trade-summary_v1_v002 create_emr_steps rendered 02-26T17:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-02-26T17:00:00+00:00'), ('task_id', 'create_emr_steps')]
2266103 07-07T08:00:28.982883+00:00 exchange-trade-summary_v1_v002 graph 06-30T15:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-30T15:00:00+00:00')]
2266102 07-07T08:00:28.959895+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps success 07-07T07:00:00+00:00 data.engineers@viooh.com
2266099 07-07T08:00:27.994480+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps cli_run 07-07T07:00:00+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'create_cluster_and_add_emr_steps', '2024-07-07T07:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
2266098 07-07T08:00:27.944786+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps running 07-07T07:00:00+00:00 data.engineers@viooh.com
2266097 07-07T08:00:27.173786+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps cli_run 07-07T07:00:00+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'create_cluster_and_add_emr_steps', '2024-07-07T07:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
2266091 07-07T08:00:24.782061+00:00 exchange-trade-summary_v1_v002 create_emr_steps rendered 02-27T07:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-02-27T07:00:00+00:00'), ('task_id', 'create_emr_steps')]
2266075 07-07T08:00:19.373350+00:00 exchange-trade-summary_v1_v002 graph 06-27T15:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-27T15:00:00+00:00')]
2266070 07-07T08:00:17.197671+00:00 exchange-trade-summary_v1_v002 check_cluster_status rendered 02-28T15:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-02-28T15:00:00+00:00'), ('task_id', 'check_cluster_status')]
2266059 07-07T08:00:13.011249+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps xcom 03-25T16:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-03-25T16:00:00+00:00'), ('task_id', 'create_cluster_and_add_emr_steps')]
2266050 07-07T08:00:10.129936+00:00 exchange-trade-summary_v1_v002 create_emr_steps success 07-07T07:00:00+00:00 data.engineers@viooh.com
2266046 07-07T08:00:08.222726+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps rendered 02-28T03:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-02-28T03:00:00+00:00'), ('task_id', 'create_cluster_and_add_emr_steps')]
2266045 07-07T08:00:07.969861+00:00 exchange-trade-summary_v1_v002 create_emr_steps cli_run 07-07T07:00:00+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'create_emr_steps', '2024-07-07T07:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
2266044 07-07T08:00:07.938115+00:00 exchange-trade-summary_v1_v002 create_emr_steps running 07-07T07:00:00+00:00 data.engineers@viooh.com
2266042 07-07T08:00:07.133507+00:00 exchange-trade-summary_v1_v002 create_emr_steps cli_run 07-07T07:00:00+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'create_emr_steps', '2024-07-07T07:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
2266037 07-07T08:00:03.507046+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps xcom 02-27T17:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-02-27T17:00:00+00:00'), ('task_id', 'create_cluster_and_add_emr_steps')]
2266033 07-07T08:00:01.247562+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps xcom 03-26T05:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-03-26T05:00:00+00:00'), ('task_id', 'create_cluster_and_add_emr_steps')]