AmineTMIRI/backend
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

clean code

Browse Source
This commit is contained in:
MuslemRahimi 2024-07-22 16:57:44 +02:00
parent d50138311f
commit 1677454919
2 changed files with 2 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
app/main.py
View File

@ -6,13 +6,11 @@ import re
import os import os
import secrets import secrets
from typing import List, Dict, Set from typing import List, Dict, Set
from datetime import datetime, timedelta
# Third-party library imports # Third-party library imports
import numpy as np import numpy as np
import pandas as pd import pandas as pd
import orjson import orjson
import aiohttp import aiohttp
import pytz
import redis import redis
from dotenv import load_dotenv from dotenv import load_dotenv
from pydantic import BaseModel, Field from pydantic import BaseModel, Field

15
app/primary_cron_job.py
View File

@ -1,18 +1,7 @@
import pytz from datetime import datetime
from datetime import datetime, timedelta
from urllib.request import urlopen
import certifi
import json
import ujson
import schedule import schedule
import time import time
import subprocess import subprocess
import asyncio
import aiohttp
import pytz
import sqlite3
import pandas as pd
import numpy as np
import threading # Import threading module for parallel execution import threading # Import threading module for parallel execution
import logging # Import logging module import logging # Import logging module
from logging.handlers import RotatingFileHandler from logging.handlers import RotatingFileHandler
@ -468,7 +457,7 @@ schedule.every().saturday.at("05:00").do(run_threaded, run_ownership_stats).tag(
schedule.every(1).minutes.do(run_threaded, run_cron_portfolio).tag('portfolio_job') schedule.every(1).minutes.do(run_threaded, run_cron_portfolio).tag('portfolio_job')
schedule.every(5).minutes.do(run_threaded, run_cron_market_movers).tag('market_movers_job') schedule.every(5).minutes.do(run_threaded, run_cron_market_movers).tag('market_movers_job')
schedule.every(5).minutes.do(run_threaded, run_dashboard).tag('dashboard_job') schedule.every(2).minutes.do(run_threaded, run_dashboard).tag('dashboard_job')
schedule.every(15).minutes.do(run_threaded, run_cron_market_news).tag('market_news_job') schedule.every(15).minutes.do(run_threaded, run_cron_market_news).tag('market_news_job')
schedule.every(10).minutes.do(run_threaded, run_one_day_price).tag('one_day_price_job') schedule.every(10).minutes.do(run_threaded, run_one_day_price).tag('one_day_price_job')