We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 1c23ae2 commit 391e576Copy full SHA for 391e576
packages/service-library/src/servicelib/rabbitmq/rpc_interfaces/async_jobs/async_jobs.py
@@ -21,6 +21,7 @@
21
before_sleep_log,
22
retry,
23
retry_if_exception_type,
24
+ stop_after_attempt,
25
stop_after_delay,
26
wait_fixed,
27
wait_random_exponential,
@@ -129,9 +130,9 @@ async def submit(
129
130
_DEFAULT_RPC_RETRY_POLICY: dict[str, Any] = {
131
"retry": retry_if_exception_type((RemoteMethodNotRegisteredError,)),
132
"wait": wait_random_exponential(max=20),
- "stop": stop_after_delay(60),
133
+ "stop": stop_after_attempt(30),
134
"reraise": True,
- "before_sleep": before_sleep_log(_logger, logging.INFO),
135
+ "before_sleep": before_sleep_log(_logger, logging.WARNING),
136
}
137
138
0 commit comments