Skip to content

A
alpha-mind
Commit 6ce5596b authored by Dr.李's avatar Dr.李
Browse files
Options

update

parent 8aa8c730
Hide whitespace changes
Inline Side-by-side
Showing with 4 additions and 2 deletions
scripts/update_uqer_data_postgres.py
View file @ 6ce5596b
...@@ -13,6 +13,7 @@ import uqer ...@@ -13,6 +13,7 @@ import uqer
import sqlalchemy import sqlalchemy
import numpy as np import numpy as np
import pandas as pd import pandas as pd
import pendulum
from airflow.operators.python_operator import PythonOperator from airflow.operators.python_operator import PythonOperator
from airflow.operators.email_operator import EmailOperator from airflow.operators.email_operator import EmailOperator
from airflow.sensors.external_task_sensor import ExternalTaskSensor from airflow.sensors.external_task_sensor import ExternalTaskSensor
...@@ -30,7 +31,8 @@ from alphamind.api import risk_styles ...@@ -30,7 +31,8 @@ from alphamind.api import risk_styles
uqer.DataAPI.api_base.timeout = 300 uqer.DataAPI.api_base.timeout = 300
start_date = dt.datetime(2018, 7, 15) local_tz = pendulum.timezone("Asia/Shanghai")
start_date = dt.datetime(2018, 7, 15, tzinfo=local_tz)
dag_name = 'update_uqer_data_postgres' dag_name = 'update_uqer_data_postgres'
default_args = { default_args = {
...@@ -887,4 +889,4 @@ factor_master_task.set_upstream(uqer_task) ...@@ -887,4 +889,4 @@ factor_master_task.set_upstream(uqer_task)
if __name__ == '__main__': if __name__ == '__main__':
update_universe(ds='2018-05-09') update_uqer_index_components(ds='2018-07-16')
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment