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 | real_time_pd_dag | basic_cash_flow_task |
|
PythonOperator |
|
|
0:00:21.724006 | 9178215 |
|
airflow | 6 | default |
|
2 | ||||
success | real_time_pd_dag | basic_position_task |
|
PythonOperator |
|
|
0:00:24.614963 | 9178214 |
|
airflow | 9 | default |
|
2 | ||||
success | real_time_pd_dag | basic_portfolio_risk_task |
|
PythonOperator |
|
|
0:00:03.104354 | 9178213 |
|
airflow | 2 | default |
|
2 | ||||
success | real_time_pd_dag | trade_notification_task |
|
PythonOperator |
|
|
0:00:05.263070 | 9178212 |
|
airflow | 1 | default |
|
2 | ||||
success | real_time_pd_dag | basic_underlyer_position_task |
|
PythonOperator |
|
|
0:00:05.112844 | 9178211 |
|
airflow | 4 | default |
|
2 | ||||
success | ctp_quote_dag | update_ctp_quotes_task |
|
PythonOperator |
|
|
0:00:01.413560 | 9178210 |
|
airflow | 1 | default |
|
2 | ||||
success | ctp_quote_dag | update_ctp_quotes_task |
|
PythonOperator |
|
|
0:00:01.596117 | 9178209 |
|
airflow | 1 | default |
|
2 | ||||
success | ctp_quote_dag | update_ctp_quotes_task |
|
PythonOperator |
|
|
0:00:01.497643 | 9178208 |
|
airflow | 1 | default |
|
2 | ||||
success | ctp_quote_dag | update_ctp_quotes_task |
|
PythonOperator |
|
|
0:00:01.560817 | 9178207 |
|
airflow | 1 | default |
|
2 | ||||
success | real_time_pd_dag | real_time_risk_task |
|
PythonOperator |
|
|
0:00:02.289476 | 9178206 |
|
airflow | 1 | default |
|
2 | ||||
success | real_time_pd_dag | real_time_mega_report_task |
|
PythonOperator |
|
|
0:00:07.040424 | 9178205 |
|
airflow | 1 | default |
|
2 | ||||
success | real_time_pd_dag | real_time_portfolio_trades_task |
|
PythonOperator |
|
|
0:00:03.844908 | 9178204 |
|
airflow | 1 | default |
|
2 | ||||
success | real_time_pd_dag | real_time_expiring_position_task |
|
PythonOperator |
|
|
0:00:03.170965 | 9178203 |
|
airflow | 1 | default |
|
2 | ||||
success | real_time_pd_dag | real_time_position_task |
|
PythonOperator |
|
|
0:00:06.952579 | 9178202 |
|
airflow | 2 | default |
|
2 | ||||
success | real_time_pd_dag | real_time_pnl_task |
|
PythonOperator |
|
|
0:00:05.333546 | 9178201 |
|
airflow | 2 | default |
|
2 | ||||
success | real_time_pd_dag | real_time_valuation_task |
|
PythonOperator |
|
|
0:00:06.935550 | 9178200 |
|
airflow | 1 | default |
|
2 | ||||
success | real_time_pd_dag | basic_risks_task |
|
PythonOperator |
|
|
0:00:01.766491 | 9178199 |
|
airflow | 8 | default |
|
2 | ||||
success | ctp_quote_dag | update_ctp_quotes_task |
|
PythonOperator |
|
|
0:00:03.642837 | 9178198 |
|
airflow | 1 | default |
|
2 | ||||
success | real_time_pd_dag | basic_cash_flow_task |
|
PythonOperator |
|
|
0:00:22.264181 | 9178197 |
|
airflow | 6 | default |
|
2 | ||||
success | real_time_pd_dag | basic_position_task |
|
PythonOperator |
|
|
0:00:23.942410 | 9178196 |
|
airflow | 9 | default |
|
2 | ||||
success | real_time_pd_dag | basic_underlyer_position_task |
|
PythonOperator |
|
|
0:00:04.968723 | 9178195 |
|
airflow | 4 | default |
|
2 | ||||
success | real_time_pd_dag | trade_notification_task |
|
PythonOperator |
|
|
0:00:05.027844 | 9178194 |
|
airflow | 1 | default |
|
2 | ||||
success | real_time_pd_dag | basic_portfolio_risk_task |
|
PythonOperator |
|
|
0:00:04.202993 | 9178193 |
|
airflow | 2 | default |
|
2 | ||||
success | real_time_pd_dag | basic_reference_data_task |
|
PythonOperator |
|
|
0:00:05.470664 | 9178192 |
|
airflow | 3 | default |
|
2 | ||||
success | real_time_pd_dag | basic_cash_flow_today_task |
|
PythonOperator |
|
|
0:00:03.187763 | 9178191 |
|
airflow | 3 | default |
|
2 | ||||
success | ctp_quote_dag | update_ctp_quotes_task |
|
PythonOperator |
|
|
0:00:01.687043 | 9178190 |
|
airflow | 1 | default |
|
2 | ||||
success | ctp_quote_dag | update_ctp_quotes_task |
|
PythonOperator |
|
|
0:00:01.608819 | 9178189 |
|
airflow | 1 | default |
|
2 | ||||
success | ctp_quote_dag | update_ctp_quotes_task |
|
PythonOperator |
|
|
0:00:01.539403 | 9178188 |
|
airflow | 1 | default |
|
2 | ||||
success | ctp_quote_dag | update_ctp_quotes_task |
|
PythonOperator |
|
|
0:00:01.447661 | 9178187 |
|
airflow | 1 | default |
|
2 | ||||
success | real_time_pd_dag | real_time_risk_task |
|
PythonOperator |
|
|
0:00:02.700777 | 9178186 |
|
airflow | 1 | default |
|
2 | ||||
success | real_time_pd_dag | real_time_mega_report_task |
|
PythonOperator |
|
|
0:00:07.187845 | 9178185 |
|
airflow | 1 | default |
|
2 | ||||
success | real_time_pd_dag | real_time_pnl_task |
|
PythonOperator |
|
|
0:00:05.482210 | 9178184 |
|
airflow | 2 | default |
|
2 | ||||
success | real_time_pd_dag | real_time_position_task |
|
PythonOperator |
|
|
0:00:06.802626 | 9178183 |
|
airflow | 2 | default |
|
2 | ||||
success | real_time_pd_dag | real_time_valuation_task |
|
PythonOperator |
|
|
0:00:06.918402 | 9178182 |
|
airflow | 1 | default |
|
2 | ||||
success | real_time_pd_dag | real_time_portfolio_trades_task |
|
PythonOperator |
|
|
0:00:03.471241 | 9178181 |
|
airflow | 1 | default |
|
2 | ||||
success | real_time_pd_dag | real_time_expiring_position_task |
|
PythonOperator |
|
|
0:00:02.710785 | 9178180 |
|
airflow | 1 | default |
|
2 | ||||
success | real_time_pd_dag | basic_risks_task |
|
PythonOperator |
|
|
0:00:02.446418 | 9178179 |
|
airflow | 8 | default |
|
2 | ||||
success | ctp_quote_dag | update_ctp_quotes_task |
|
PythonOperator |
|
|
0:00:03.088594 | 9178178 |
|
airflow | 1 | default |
|
2 | ||||
success | real_time_pd_dag | basic_position_task |
|
PythonOperator |
|
|
0:00:24.159339 | 9178177 |
|
airflow | 9 | default |
|
2 | ||||
success | real_time_pd_dag | basic_underlyer_position_task |
|
PythonOperator |
|
|
0:00:05.692705 | 9178176 |
|
airflow | 4 | default |
|
2 | ||||
success | real_time_pd_dag | basic_cash_flow_today_task |
|
PythonOperator |
|
|
0:00:02.980722 | 9178175 |
|
airflow | 3 | default |
|
2 | ||||
success | real_time_pd_dag | trade_notification_task |
|
PythonOperator |
|
|
0:00:05.294193 | 9178174 |
|
airflow | 1 | default |
|
2 | ||||
success | real_time_pd_dag | basic_reference_data_task |
|
PythonOperator |
|
|
0:00:05.526345 | 9178173 |
|
airflow | 3 | default |
|
2 | ||||
success | real_time_pd_dag | basic_cash_flow_task |
|
PythonOperator |
|
|
0:00:24.526009 | 9178172 |
|
airflow | 6 | default |
|
2 | ||||
success | real_time_pd_dag | basic_portfolio_risk_task |
|
PythonOperator |
|
|
0:00:04.965889 | 9178171 |
|
airflow | 2 | default |
|
2 | ||||
success | ctp_quote_dag | update_ctp_quotes_task |
|
PythonOperator |
|
|
0:00:01.439514 | 9178170 |
|
airflow | 1 | default |
|
2 | ||||
success | ctp_quote_dag | update_ctp_quotes_task |
|
PythonOperator |
|
|
0:00:01.600752 | 9178169 |
|
airflow | 1 | default |
|
2 | ||||
success | ctp_quote_dag | update_ctp_quotes_task |
|
PythonOperator |
|
|
0:00:01.603901 | 9178168 |
|
airflow | 1 | default |
|
2 | ||||
success | ctp_quote_dag | update_ctp_quotes_task |
|
PythonOperator |
|
|
0:00:01.558940 | 9178167 |
|
airflow | 1 | default |
|
2 | ||||
success | real_time_pd_dag | real_time_risk_task |
|
PythonOperator |
|
|
0:00:02.546115 | 9178166 |
|
airflow | 1 | default |
|
2 | ||||
success | real_time_pd_dag | real_time_mega_report_task |
|
PythonOperator |
|
|
0:00:07.571438 | 9178165 |
|
airflow | 1 | default |
|
2 | ||||
success | real_time_pd_dag | real_time_portfolio_trades_task |
|
PythonOperator |
|
|
0:00:03.671595 | 9178164 |
|
airflow | 1 | default |
|
2 | ||||
success | real_time_pd_dag | real_time_expiring_position_task |
|
PythonOperator |
|
|
0:00:03.227186 | 9178163 |
|
airflow | 1 | default |
|
2 | ||||
success | real_time_pd_dag | real_time_valuation_task |
|
PythonOperator |
|
|
0:00:06.855711 | 9178162 |
|
airflow | 1 | default |
|
2 | ||||
success | real_time_pd_dag | real_time_pnl_task |
|
PythonOperator |
|
|
0:00:04.818731 | 9178161 |
|
airflow | 2 | default |
|
2 | ||||
success | real_time_pd_dag | real_time_position_task |
|
PythonOperator |
|
|
0:00:07.286463 | 9178160 |
|
airflow | 2 | default |
|
2 | ||||
success | real_time_pd_dag | basic_risks_task |
|
PythonOperator |
|
|
0:00:01.960273 | 9178159 |
|
airflow | 8 | default |
|
2 | ||||
success | ctp_quote_dag | update_ctp_quotes_task |
|
PythonOperator |
|
|
0:00:03.277336 | 9178158 |
|
airflow | 1 | default |
|
2 | ||||
success | real_time_pd_dag | basic_reference_data_task |
|
PythonOperator |
|
|
0:00:04.556172 | 9178157 |
|
airflow | 3 | default |
|
2 | ||||
success | real_time_pd_dag | basic_underlyer_position_task |
|
PythonOperator |
|
|
0:00:08.574463 | 9178156 |
|
airflow | 4 | default |
|
2 | ||||
success | real_time_pd_dag | trade_notification_task |
|
PythonOperator |
|
|
0:00:06.718910 | 9178155 |
|
airflow | 1 | default |
|
2 | ||||
success | real_time_pd_dag | basic_position_task |
|
PythonOperator |
|
|
0:00:25.996409 | 9178154 |
|
airflow | 9 | default |
|
2 | ||||
success | real_time_pd_dag | basic_cash_flow_task |
|
PythonOperator |
|
|
0:00:23.128730 | 9178153 |
|
airflow | 6 | default |
|
2 | ||||
success | real_time_pd_dag | basic_cash_flow_today_task |
|
PythonOperator |
|
|
0:00:05.322242 | 9178152 |
|
airflow | 3 | default |
|
2 | ||||
success | real_time_pd_dag | basic_portfolio_risk_task |
|
PythonOperator |
|
|
0:00:03.848093 | 9178151 |
|
airflow | 2 | default |
|
2 | ||||
success | ctp_quote_dag | update_ctp_quotes_task |
|
PythonOperator |
|
|
0:00:01.477994 | 9178150 |
|
airflow | 1 | default |
|
2 | ||||
success | ctp_quote_dag | update_ctp_quotes_task |
|
PythonOperator |
|
|
0:00:01.623109 | 9178149 |
|
airflow | 1 | default |
|
2 | ||||
success | ctp_quote_dag | update_ctp_quotes_task |
|
PythonOperator |
|
|
0:00:01.558156 | 9178148 |
|
airflow | 1 | default |
|
2 | ||||
success | ctp_quote_dag | update_ctp_quotes_task |
|
PythonOperator |
|
|
0:00:01.517910 | 9178147 |
|
airflow | 1 | default |
|
2 | ||||
success | real_time_pd_dag | real_time_risk_task |
|
PythonOperator |
|
|
0:00:02.799158 | 9178146 |
|
airflow | 1 | default |
|
2 | ||||
success | real_time_pd_dag | real_time_mega_report_task |
|
PythonOperator |
|
|
0:00:07.373727 | 9178145 |
|
airflow | 1 | default |
|
2 | ||||
success | real_time_pd_dag | real_time_valuation_task |
|
PythonOperator |
|
|
0:00:05.291901 | 9178144 |
|
airflow | 1 | default |
|
2 | ||||
success | real_time_pd_dag | real_time_portfolio_trades_task |
|
PythonOperator |
|
|
0:00:03.374247 | 9178143 |
|
airflow | 1 | default |
|
2 | ||||
success | real_time_pd_dag | real_time_pnl_task |
|
PythonOperator |
|
|
0:00:04.641978 | 9178142 |
|
airflow | 2 | default |
|
2 | ||||
success | real_time_pd_dag | real_time_position_task |
|
PythonOperator |
|
|
0:00:07.348009 | 9178141 |
|
airflow | 2 | default |
|
2 | ||||
success | real_time_pd_dag | real_time_expiring_position_task |
|
PythonOperator |
|
|
0:00:04.373016 | 9178140 |
|
airflow | 1 | default |
|
2 | ||||
success | real_time_pd_dag | basic_risks_task |
|
PythonOperator |
|
|
0:00:02.014603 | 9178139 |
|
airflow | 8 | default |
|
2 | ||||
success | ctp_quote_dag | update_ctp_quotes_task |
|
PythonOperator |
|
|
0:00:03.448738 | 9178138 |
|
airflow | 1 | default |
|
2 | ||||
success | real_time_pd_dag | basic_cash_flow_today_task |
|
PythonOperator |
|
|
0:00:03.609431 | 9178137 |
|
airflow | 3 | default |
|
2 | ||||
success | real_time_pd_dag | basic_portfolio_risk_task |
|
PythonOperator |
|
|
0:00:02.566120 | 9178136 |
|
airflow | 2 | default |
|
2 | ||||
success | real_time_pd_dag | trade_notification_task |
|
PythonOperator |
|
|
0:00:03.857046 | 9178135 |
|
airflow | 1 | default |
|
2 | ||||
success | real_time_pd_dag | basic_underlyer_position_task |
|
PythonOperator |
|
|
0:00:06.326149 | 9178134 |
|
airflow | 4 | default |
|
2 | ||||
success | real_time_pd_dag | basic_position_task |
|
PythonOperator |
|
|
0:00:24.394833 | 9178133 |
|
airflow | 9 | default |
|
2 | ||||
success | real_time_pd_dag | basic_reference_data_task |
|
PythonOperator |
|
|
0:00:04.966057 | 9178132 |
|
airflow | 3 | default |
|
2 | ||||
success | real_time_pd_dag | basic_cash_flow_task |
|
PythonOperator |
|
|
0:00:24.013292 | 9178131 |
|
airflow | 6 | default |
|
2 | ||||
success | ctp_quote_dag | update_ctp_quotes_task |
|
PythonOperator |
|
|
0:00:01.422741 | 9178130 |
|
airflow | 1 | default |
|
2 | ||||
success | ctp_quote_dag | update_ctp_quotes_task |
|
PythonOperator |
|
|
0:00:01.604755 | 9178129 |
|
airflow | 1 | default |
|
2 | ||||
success | ctp_quote_dag | update_ctp_quotes_task |
|
PythonOperator |
|
|
0:00:01.484396 | 9178128 |
|
airflow | 1 | default |
|
2 | ||||
success | ctp_quote_dag | update_ctp_quotes_task |
|
PythonOperator |
|
|
0:00:01.598024 | 9178127 |
|
airflow | 1 | default |
|
2 | ||||
success | real_time_pd_dag | real_time_mega_report_task |
|
PythonOperator |
|
|
0:00:06.765589 | 9178126 |
|
airflow | 1 | default |
|
2 | ||||
success | real_time_pd_dag | real_time_risk_task |
|
PythonOperator |
|
|
0:00:02.526999 | 9178125 |
|
airflow | 1 | default |
|
2 | ||||
success | real_time_pd_dag | real_time_pnl_task |
|
PythonOperator |
|
|
0:00:04.869491 | 9178124 |
|
airflow | 2 | default |
|
2 | ||||
success | real_time_pd_dag | real_time_expiring_position_task |
|
PythonOperator |
|
|
0:00:02.451926 | 9178123 |
|
airflow | 1 | default |
|
2 | ||||
success | real_time_pd_dag | real_time_position_task |
|
PythonOperator |
|
|
0:00:07.479377 | 9178122 |
|
airflow | 2 | default |
|
2 | ||||
success | real_time_pd_dag | real_time_portfolio_trades_task |
|
PythonOperator |
|
|
0:00:02.990867 | 9178121 |
|
airflow | 1 | default |
|
2 | ||||
success | real_time_pd_dag | real_time_valuation_task |
|
PythonOperator |
|
|
0:00:07.125067 | 9178120 |
|
airflow | 1 | default |
|
2 | ||||
success | real_time_pd_dag | basic_risks_task |
|
PythonOperator |
|
|
0:00:02.170697 | 9178119 |
|
airflow | 8 | default |
|
2 | ||||
success | ctp_quote_dag | update_ctp_quotes_task |
|
PythonOperator |
|
|
0:00:02.826630 | 9178118 |
|
airflow | 1 | default |
|
2 | ||||
success | real_time_pd_dag | basic_underlyer_position_task |
|
PythonOperator |
|
|
0:00:05.202143 | 9178117 |
|
airflow | 4 | default |
|
2 | ||||
success | real_time_pd_dag | basic_portfolio_risk_task |
|
PythonOperator |
|
|
0:00:04.977993 | 9178116 |
|
airflow | 2 | default |
|
2 |