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

Remove wrong logger.

pull/481/head
Andrey Dolgolev 2021-12-13 16:58:47 +02:00
rodzic 875c9850c9
commit c8a3cacb21
2 zmienionych plików z 3 dodań i 6 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

4
backend/moonstreamapi/admin/cli.py
Wyświetl plik

@ -8,11 +8,9 @@ import json
import os import os
from posix import listdir from posix import listdir
from typing import Optional from typing import Optional
from moonstreamapi.providers import moonworm_provider
from moonstreamdb.db import SessionLocal from moonstreamdb.db import SessionLocal
from sqlalchemy.orm import with_expression
from ..settings import BUGOUT_BROOD_URL, BUGOUT_SPIRE_URL, MOONSTREAM_APPLICATION_ID from ..settings import BUGOUT_BROOD_URL, BUGOUT_SPIRE_URL, MOONSTREAM_APPLICATION_ID
from ..web3_provider import yield_web3_provider from ..web3_provider import yield_web3_provider
@ -118,7 +116,7 @@ def migrations_run(args: argparse.Namespace) -> None:
def moonworm_tasks_list_handler(args: argparse.Namespace) -> None: def moonworm_tasks_list_handler(args: argparse.Namespace) -> None:
moonworm_tasks.get_list_of_address() moonworm_tasks.get_list_of_addresses()
def moonworm_tasks_add_subscription_handler(args: argparse.Namespace) -> None: def moonworm_tasks_add_subscription_handler(args: argparse.Namespace) -> None:

5
backend/moonstreamapi/admin/moonworm_tasks.py
Wyświetl plik

@ -20,7 +20,7 @@ def get_list_of_addresses():
entries = get_all_entries_from_search( entries = get_all_entries_from_search(
journal_id=MOONSTREAM_MOONWORM_TASKS_JOURNAL, journal_id=MOONSTREAM_MOONWORM_TASKS_JOURNAL,
search_query=f"", search_query=f"?tag:type:event ?tag:type:function",
limit=100, limit=100,
token=MOONSTREAM_ADMIN_ACCESS_TOKEN, token=MOONSTREAM_ADMIN_ACCESS_TOKEN,
) )
@ -53,7 +53,6 @@ def add_subscription(id: str):
s3_client = boto3.client("s3") s3_client = boto3.client("s3")
if subscription_resource.resource_data["abi"] is not None: if subscription_resource.resource_data["abi"] is not None:
logger.error(f"Resource don't have abi.")
bucket = subscription_resource.resource_data["bucket"] bucket = subscription_resource.resource_data["bucket"]
key = subscription_resource.resource_data["s3_path"] key = subscription_resource.resource_data["s3_path"]
@ -72,7 +71,7 @@ def add_subscription(id: str):
except s3_client.exceptions.NoSuchKey as e: except s3_client.exceptions.NoSuchKey as e:
logger.error( logger.error(
f"Error getting Abi for subscription {str(subscription_resource.subscription_id)} S3 {s3_path} does not exist : {str(e)}" f"Error getting Abi for subscription {str(id)} S3 {s3_path} does not exist : {str(e)}"
) )
abi = json.loads(response["Body"].read()) abi = json.loads(response["Body"].read())