clean code

app/create_crypto_db.py

@@ -1,7 +1,6 @@
 import aiohttp
 import asyncio
 import sqlite3
-import certifi
 import json
 import ujson
 import pandas as pd
@@ -10,8 +9,7 @@
 import re
 import pandas as pd
 from datetime import datetime
-import subprocess
-import time
+
 import warnings
 import requests
 

app/create_etf_db.py

@@ -1,7 +1,6 @@
 import aiohttp
 import asyncio
 import sqlite3
-import certifi
 import json
 import ujson
 import pandas as pd
@@ -10,8 +9,7 @@
 import re
 import pandas as pd
 from datetime import datetime
-import subprocess
-import time
+
 import warnings
 
 from dotenv import load_dotenv

app/cron_analyst_db.py

@@ -1,7 +1,6 @@
 from benzinga import financial_data
 import requests
-from datetime import datetime, timedelta, date
-from collections import defaultdict
+from datetime import datetime
 import numpy as np
 from scipy.stats import norm
 import time

app/cron_bull_bear_say.py

@@ -1,5 +1,4 @@
 import aiohttp
-import aiofiles
 import ujson
 import sqlite3
 import asyncio

app/cron_insider_trading.py

@@ -3,7 +3,6 @@
 import aiohttp
 import sqlite3
 from datetime import datetime
-import pytz
 from aiofiles import open as async_open
 
 from dotenv import load_dotenv

app/cron_market_movers.py

@@ -2,8 +2,6 @@
 import ujson
 import sqlite3
 import pandas as pd
-import numpy as np
-from collections import defaultdict
 import asyncio
 import aiohttp
 import pytz

app/cron_shareholders.py

@@ -1,10 +1,8 @@
-import aiohttp
 import ujson
 import sqlite3
 import asyncio
 import pandas as pd
 from tqdm import tqdm
-from collections import defaultdict
 
 
 query_template = """
@@ -21,7 +19,7 @@ async def save_as_json(symbol, data):
         ujson.dump(data, file)
 
 
-async def get_data(ticker, stock_symbols, etf_symbols, con, etf_con):
+async def get_data(ticker, etf_symbols, con, etf_con):
     if ticker in etf_symbols:
         table_name = 'etfs'
     else:
@@ -71,7 +69,7 @@ async def run():
     total_symbols = stock_symbols + etf_symbols
 
     for ticker in tqdm(total_symbols):
-        shareholders_list = await get_data(ticker, stock_symbols, etf_symbols, con, etf_con)
+        shareholders_list = await get_data(ticker, etf_symbols, con, etf_con)
         if len(shareholders_list) > 0:
             await save_as_json(ticker, shareholders_list)
 

app/cron_var.py

@@ -4,7 +4,6 @@
 import numpy as np
 import ujson
 import asyncio
-import aiohttp
 import sqlite3
 from tqdm import tqdm