enhance test_parallel_entity_creation

Author: Matthias Zimmermann

.env.testing

@@ -47,3 +47,10 @@ WALLET_PASSWORD_17=s3cret
 WALLET_PASSWORD_18=s3cret
 WALLET_PASSWORD_19=s3cret
 WALLET_PASSWORD_20=s3cret
+
+# Parallel operations configuration
+# E.g. test_entity_create_parallel.py
+NUM_CLIENTS = 20
+NUM_TX = 10
+BATCH_SIZE = 100
+VERIFY_SAMPLE_SIZE = 5

src/arkiv/module.py

@@ -82,7 +82,7 @@ def execute(
         receipt: TransactionReceipt = to_receipt(
             client.arkiv.contract, tx_hash, tx_receipt
         )
-        logger.info(f"Arkiv receipt: {receipt}")
+        logger.debug(f"Arkiv receipt: {receipt}")
         return receipt
 
     def create_entity(
@@ -179,23 +179,26 @@ def get_entity(self, entity_key: EntityKey, fields: int = ALL) -> Entity:
 
         # HINT: rpc methods to fetch entity content might change this is the place to adapt
         # get and decode payload if requested
-        if fields & PAYLOAD:
-            payload = self._get_storage_value(entity_key)
-
-        # get and decode annotations and/or metadata if requested
-        if fields & METADATA or fields & ANNOTATIONS:
-            metadata_all = self._get_entity_metadata(entity_key)
-
-            if fields & METADATA:
-                # Convert owner address to checksummed format
-                owner = self._get_owner(metadata_all)
-                expires_at_block = self._get_expires_at_block(metadata_all)
-
-            if fields & ANNOTATIONS:
-                annotations = merge_annotations(
-                    string_annotations=metadata_all.get("stringAnnotations", []),
-                    numeric_annotations=metadata_all.get("numericAnnotations", []),
-                )
+        try:
+            if fields & PAYLOAD:
+                payload = self._get_storage_value(entity_key)
+
+            # get and decode annotations and/or metadata if requested
+            if fields & METADATA or fields & ANNOTATIONS:
+                metadata_all = self._get_entity_metadata(entity_key)
+
+                if fields & METADATA:
+                    # Convert owner address to checksummed format
+                    owner = self._get_owner(metadata_all)
+                    expires_at_block = self._get_expires_at_block(metadata_all)
+
+                if fields & ANNOTATIONS:
+                    annotations = merge_annotations(
+                        string_annotations=metadata_all.get("stringAnnotations", []),
+                        numeric_annotations=metadata_all.get("numericAnnotations", []),
+                    )
+        except Exception as e:
+            logger.warning(f"Error fetching entity[{entity_key}]: {e}")
 
         # Create and return entity
         return Entity(

src/arkiv/utils.py

@@ -301,7 +301,7 @@ def merge_annotations(
     if string_annotations:
         # example: [AttributeDict({'key': 'type', 'value': 'Greeting'})]
         for element in string_annotations:
-            logger.info(f"String annotation element: {element}")
+            logger.debug(f"String annotation element: {element}")
             if isinstance(element.value, str):
                 annotations[element.key] = element.value
             else:
@@ -312,7 +312,7 @@ def merge_annotations(
     if numeric_annotations:
         # example: [AttributeDict({'key': 'version', 'value': 1})]
         for element in numeric_annotations:
-            logger.info(f"Numeric annotation element: {element}")
+            logger.debug(f"Numeric annotation element: {element}")
             if isinstance(element.value, int):
                 annotations[element.key] = element.value
             else: