ets-labs/python-dependency-injector
1
1
Fork 0
mirror of https://github.com/ets-labs/python-dependency-injector.git synced 2025-06-17 12:03:13 +03:00
Code Issues Packages Projects Releases Wiki Activity

Merge 9273ab3c45 into 8460465b5e

Browse Source
This commit is contained in:
Gen Xu 2025-06-01 21:21:16 +03:00 committed by GitHub
commit edd21a6be2
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 14 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
src/dependency_injector/providers.pxd
View File

@ -496,6 +496,8 @@ cdef inline void __async_prepare_args_kwargs_callback(
for value, (key, _) in zip(result, future_args_kwargs): for value, (key, _) in zip(result, future_args_kwargs):
args[key] = value args[key] = value
except Exception as exception: except Exception as exception:
exception.__traceback__.tb_frame.f_locals.clear()
exception.__traceback__.tb_frame.f_locals.update(locals())
future_result.set_exception(exception) future_result.set_exception(exception)
else: else:
future_result.set_result(args) future_result.set_result(args)
@ -544,6 +546,8 @@ cdef inline void __async_inject_attributes_callback(object future_result, object
for name, value in attributes.items(): for name, value in attributes.items():
setattr(instance, name, value) setattr(instance, name, value)
except Exception as exception: except Exception as exception:
exception.__traceback__.tb_frame.f_locals.clear()
exception.__traceback__.tb_frame.f_locals.update(locals())
future_result.set_exception(exception) future_result.set_exception(exception)
else: else:
future_result.set_result(instance) future_result.set_result(instance)
@ -600,15 +604,20 @@ cdef inline object __call(
asyncio.ensure_future(args_kwargs_ready) asyncio.ensure_future(args_kwargs_ready)
return future_result return future_result
try:
return call(*args, **kwargs) return call(*args, **kwargs)
except Exception as exception:
exception.__traceback__.tb_frame.f_locals.clear()
exception.__traceback__.tb_frame.f_locals.update(locals())
raise exception
cdef inline void __async_call_callback(object future_result, object call, object future): cdef inline void __async_call_callback(object future_result, object call, object future):
try: try:
args, kwargs = future.result() args, kwargs = future.result()
result = call(*args, **kwargs) result = call(*args, **kwargs)
except Exception as exception: except Exception as exception:
exception.__traceback__.tb_frame.f_locals.clear()
exception.__traceback__.tb_frame.f_locals.update(locals())
future_result.set_exception(exception) future_result.set_exception(exception)
else: else:
if __is_future_or_coroutine(result): if __is_future_or_coroutine(result):
@ -622,6 +631,8 @@ cdef inline object __async_result_callback(object future_result, object future):
try: try:
result = future.result() result = future.result()
except Exception as exception: except Exception as exception:
exception.__traceback__.tb_frame.f_locals.clear()
exception.__traceback__.tb_frame.f_locals.update(locals())
future_result.set_exception(exception) future_result.set_exception(exception)
else: else:
future_result.set_result(result) future_result.set_result(result)