Updated version and json loads

moonstreamapi/moonstreamapi/admin/cli.py

@@ -29,7 +29,7 @@ from .migrations import (
     generate_entity_subscriptions,
     update_dashboard_subscription_key,
 )
-from .databases import databases_v2_to_v3_labels_migration
+# from .databases import databases_v2_to_v3_labels_migration
 
 logging.basicConfig(level=logging.INFO)
 logger = logging.getLogger(__name__)
@@ -310,7 +310,7 @@ def databases_v2_to_v3_labels_migration_handler(args: argparse.Namespace) -> Non
     Migrate labels in database
     """
 
-    databases_v2_to_v3_labels_migration(args.user_id, args.blockchain)
+    # databases_v2_to_v3_labels_migration(args.user_id, args.blockchain)
 
 
 def create_v3_task_handler(args: argparse.Namespace) -> None:
@@ -320,7 +320,7 @@ def create_v3_task_handler(args: argparse.Namespace) -> None:
         customer_id=args.customer_id,
         blockchain=args.blockchain,
         address=args.address,
-        abi=args.abi.read(),
+        abi=json.loads(args.abi.read()),
     )
 
 

moonstreamapi/moonstreamapi/admin/moonworm_tasks.py

@@ -106,7 +106,6 @@ def create_v3_task(
     """
     Create moonworm task for v3
     """
-
     abi_tasks = []
 
     db_engine = MoonstreamDBIndexesEngine()
@@ -114,9 +113,8 @@ def create_v3_task(
     with db_engine.yield_db_session_ctx() as db_session_v3:
 
         for task in abi:
-
             abi_selector = Web3.keccak(
-                text=abi["name"]
+                text=task["name"]
                 + "("
                 + ",".join(map(lambda x: x["type"], abi["inputs"]))
                 + ")"
@@ -141,7 +139,7 @@ def create_v3_task(
                         "historical_crawl_status": "pending",
                         "progress": 0,
                         "moonworm_task_pickedup": False,
-                        "abi": json.dumps(abi),
+                        "abi": json.dumps(task),
                     }
                 )
 

moonstreamapi/setup.py

@@ -17,7 +17,7 @@ setup(
         "fastapi",
         "moonstream",
         "moonstreamdb>=0.4.4",
-        "moonstreamdb-v3>=0.0.8",
+        "moonstreamdb-v3>=0.0.9",
         "humbug",
         "pydantic==1.10.2",
         "pyevmasm",