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

Fix typo.

pull/391/head
Andrey Dolgolev 2021-11-13 16:44:08 +02:00
rodzic 8c54d9b4fc
commit 46ab3d72b0
1 zmienionych plików z 3 dodań i 4 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

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

@ -165,7 +165,6 @@ def generate_metrics(
) )
.order_by(text("timeseries_points DESC")) .order_by(text("timeseries_points DESC"))
) )
response_metric: List[Any] = [] response_metric: List[Any] = []
for created_date, count in metrics_time_series: for created_date, count in metrics_time_series:
@ -371,7 +370,7 @@ def crawlers_start(db_session):
# already proccessd # already proccessd
already_proccessd = [] already_processed = []
for subscription in required_subscriptions.resources: for subscription in required_subscriptions.resources:
@ -397,7 +396,7 @@ def crawlers_start(db_session):
hash = hashlib.md5(abi_string.encode("utf-8")).hexdigest() hash = hashlib.md5(abi_string.encode("utf-8")).hexdigest()
if f"{address}/{hash}" in already_proccessd: if f"{address}/{hash}" in already_processed:
continue continue
s3_data_object = {} s3_data_object = {}
@ -452,7 +451,7 @@ def crawlers_start(db_session):
bucket=bucket, bucket=bucket,
hash=hash, hash=hash,
) )
already_proccessd.append(f"{address}/{hash}") already_processed.append(f"{address}/{hash}")
time.sleep(10) time.sleep(10)