From c8a3cacb21fb282799556315071b0fe338c6787d Mon Sep 17 00:00:00 2001
From: Andrey Dolgolev <andrey@simiotics.com>
Date: Mon, 13 Dec 2021 16:58:47 +0200
Subject: [PATCH] Remove wrong logger.

---
 backend/moonstreamapi/admin/cli.py            | 4 +---
 backend/moonstreamapi/admin/moonworm_tasks.py | 5 ++---
 2 files changed, 3 insertions(+), 6 deletions(-)

diff --git a/backend/moonstreamapi/admin/cli.py b/backend/moonstreamapi/admin/cli.py
index cfebac3f..109ccfcf 100644
--- a/backend/moonstreamapi/admin/cli.py
+++ b/backend/moonstreamapi/admin/cli.py
@@ -8,11 +8,9 @@ import json
 import os
 from posix import listdir
 from typing import Optional
-from moonstreamapi.providers import moonworm_provider
 
 
 from moonstreamdb.db import SessionLocal
-from sqlalchemy.orm import with_expression
 
 from ..settings import BUGOUT_BROOD_URL, BUGOUT_SPIRE_URL, MOONSTREAM_APPLICATION_ID
 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:
 
-    moonworm_tasks.get_list_of_address()
+    moonworm_tasks.get_list_of_addresses()
 
 
 def moonworm_tasks_add_subscription_handler(args: argparse.Namespace) -> None:
diff --git a/backend/moonstreamapi/admin/moonworm_tasks.py b/backend/moonstreamapi/admin/moonworm_tasks.py
index 0dd9ffe6..12a2dfb1 100644
--- a/backend/moonstreamapi/admin/moonworm_tasks.py
+++ b/backend/moonstreamapi/admin/moonworm_tasks.py
@@ -20,7 +20,7 @@ def get_list_of_addresses():
 
     entries = get_all_entries_from_search(
         journal_id=MOONSTREAM_MOONWORM_TASKS_JOURNAL,
-        search_query=f"",
+        search_query=f"?tag:type:event ?tag:type:function",
         limit=100,
         token=MOONSTREAM_ADMIN_ACCESS_TOKEN,
     )
@@ -53,7 +53,6 @@ def add_subscription(id: str):
     s3_client = boto3.client("s3")
 
     if subscription_resource.resource_data["abi"] is not None:
-        logger.error(f"Resource don't have abi.")
 
         bucket = subscription_resource.resource_data["bucket"]
         key = subscription_resource.resource_data["s3_path"]
@@ -72,7 +71,7 @@ def add_subscription(id: str):
 
         except s3_client.exceptions.NoSuchKey as e:
             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())