Skip to content

Commit c6fdc0a

Browse files
committed
no timeout
1 parent 6edb120 commit c6fdc0a

File tree

1 file changed

+3
-2
lines changed
  • packages/service-library/src/servicelib/rabbitmq/rpc_interfaces/async_jobs

1 file changed

+3
-2
lines changed

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

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,7 @@
2121
before_sleep_log,
2222
retry,
2323
retry_if_exception_type,
24+
stop_after_attempt,
2425
stop_after_delay,
2526
wait_fixed,
2627
wait_random_exponential,
@@ -129,9 +130,9 @@ async def submit(
129130
_DEFAULT_RPC_RETRY_POLICY: dict[str, Any] = {
130131
"retry": retry_if_exception_type((RemoteMethodNotRegisteredError,)),
131132
"wait": wait_random_exponential(max=20),
132-
"stop": stop_after_delay(60),
133+
"stop": stop_after_attempt(30),
133134
"reraise": True,
134-
"before_sleep": before_sleep_log(_logger, logging.INFO),
135+
"before_sleep": before_sleep_log(_logger, logging.WARNING),
135136
}
136137

137138

0 commit comments

Comments
 (0)