Commit 8aa8c730 authored by Dr.李's avatar Dr.李

update script

parent fc8a8bea
...@@ -15,7 +15,7 @@ import numpy as np ...@@ -15,7 +15,7 @@ import numpy as np
import pandas as pd import pandas as pd
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.operators.sensors import ExternalTaskSensor from airflow.sensors.external_task_sensor import ExternalTaskSensor
from airflow.models import DAG from airflow.models import DAG
from uqer import DataAPI as api from uqer import DataAPI as api
from alphamind.utilities import alpha_logger from alphamind.utilities import alpha_logger
...@@ -30,7 +30,7 @@ from alphamind.api import risk_styles ...@@ -30,7 +30,7 @@ from alphamind.api import risk_styles
uqer.DataAPI.api_base.timeout = 300 uqer.DataAPI.api_base.timeout = 300
start_date = dt.datetime(2018, 5, 4) start_date = dt.datetime(2018, 7, 15)
dag_name = 'update_uqer_data_postgres' dag_name = 'update_uqer_data_postgres'
default_args = { default_args = {
...@@ -749,7 +749,7 @@ def update_factor_master(ds, **kwargs): ...@@ -749,7 +749,7 @@ def update_factor_master(ds, **kwargs):
if not flag: if not flag:
return return
tables = [Uqer, Gogoal, Experimental, RiskExposure] tables = [Uqer, RiskExposure]
meta = MetaData(bind=engine, reflect=True) meta = MetaData(bind=engine, reflect=True)
......
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