|
@@ -2,6 +2,8 @@ import time
|
|
|
from datetime import datetime, timedelta
|
|
|
from argparse import ArgumentParser
|
|
|
|
|
|
+from tasks.data_tasks.account_position_read_avg_task import AccountPositionReadAvgTask
|
|
|
+
|
|
|
|
|
|
def main():
|
|
|
"""
|
|
@@ -13,7 +15,7 @@ def main():
|
|
|
help="Run only once for date in format of %Y-%m-%d. \
|
|
|
If no specified, run as daily jobs.")
|
|
|
args = parser.parse_args()
|
|
|
- update_account_read_avg_task = UpdateAccountInfoVersion3()
|
|
|
+ update_account_read_avg_task = AccountPositionReadAvgTask()
|
|
|
if args.run_date:
|
|
|
update_account_read_avg_task.do_task_list(dt=args.run_date)
|
|
|
else:
|