sonar

Author: sanderegg

packages/service-library/src/servicelib/rabbitmq/rpc_interfaces/async_jobs/async_jobs.py

@@ -127,7 +127,7 @@ async def submit(
 
 
 _DEFAULT_RPC_RETRY_POLICY: dict[str, Any] = {
-    "retry": retry_if_exception_type(RemoteMethodNotRegisteredError),
+    "retry": retry_if_exception_type((RemoteMethodNotRegisteredError,)),
     "wait": wait_random_exponential(max=20),
     "stop": stop_after_delay(60),
     "reraise": True,
@@ -196,6 +196,8 @@ async def wait_and_get_result(
     job_id_data: AsyncJobNameData,
     client_timeout: datetime.timedelta,
 ) -> AsyncGenerator[AsyncJobComposedResult, None]:
+    """when a job is already submitted this will wait for its completion
+    and return the composed result"""
     try:
         job_status = None
         async for job_status in _wait_for_completion(
@@ -229,7 +231,7 @@ async def wait_and_get_result(
                 job_id_data=job_id_data,
             )
         except Exception as exc:
-            raise exc from error
+            raise exc from error  # NOSONAR
         raise