mirror
/
moonstream
kopia lustrzana https://github.com/bugout-dev/moonstream
1
0
Forkuj 0
Kod Zgłoszenia Projekty Wydania Wiki Aktywność

Black formating.

pull/600/head
Andrey Dolgolev 2022-06-21 13:24:41 +03:00
rodzic ab9622b2c3
commit 96e570039c
1 zmienionych plików z 11 dodań i 3 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

14
crawlers/mooncrawl/mooncrawl/stats_worker/dashboard.py
Wyświetl plik

@ -170,7 +170,9 @@ def generate_data(
time_series = db_session.query( time_series = db_session.query(
func.generate_series( func.generate_series(
start, start + timescales_delta[timescale]["timedelta"], time_step, start,
start + timescales_delta[timescale]["timedelta"],
time_step,
).label("timeseries_points") ).label("timeseries_points")
) )
@ -692,7 +694,10 @@ def stats_generate_handler(args: argparse.Namespace):
key = subscription_by_id[subscription_id].resource_data[ key = subscription_by_id[subscription_id].resource_data[
"s3_path" "s3_path"
] ]
abi = s3_client.get_object(Bucket=bucket, Key=key,) abi = s3_client.get_object(
Bucket=bucket,
Key=key,
)
abi_json = json.loads(abi["Body"].read()) abi_json = json.loads(abi["Body"].read())
methods = generate_list_of_names( methods = generate_list_of_names(
type="function", type="function",
@ -1030,7 +1035,10 @@ def stats_generate_api_task(
bucket = subscription_by_id[subscription_id].resource_data["bucket"] bucket = subscription_by_id[subscription_id].resource_data["bucket"]
key = subscription_by_id[subscription_id].resource_data["s3_path"] key = subscription_by_id[subscription_id].resource_data["s3_path"]
abi = s3_client.get_object(Bucket=bucket, Key=key,) abi = s3_client.get_object(
Bucket=bucket,
Key=key,
)
abi_json = json.loads(abi["Body"].read()) abi_json = json.loads(abi["Body"].read())
methods = generate_list_of_names( methods = generate_list_of_names(