Skip to content

Commit e315550

Browse files
committed
fixed changes in operation model
1 parent c2132a8 commit e315550

File tree

1 file changed

+8
-5
lines changed

1 file changed

+8
-5
lines changed

ninja_extra/operation.py

Lines changed: 8 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -155,10 +155,11 @@ def run(self, request: HttpRequest, **kw: Any) -> HttpResponseBase:
155155
return error
156156
try:
157157
with self._prep_run(request, **kw) as ctx:
158-
values = self._get_values(request, kw)
158+
temporal_response = self.api.create_temporal_response(request)
159+
values = self._get_values(request, kw, temporal_response)
159160
ctx.kwargs = values
160161
result = self.view_func(context=ctx, **values)
161-
_processed_results = self._result_to_response(request, result)
162+
_processed_results = self._result_to_response(request, result, temporal_response)
162163
return _processed_results
163164
except Exception as e:
164165
if isinstance(e, TypeError) and "required positional argument" in str(e):
@@ -216,9 +217,10 @@ async def run(self, request: HttpRequest, **kw: Any) -> HttpResponseBase: # typ
216217
if error:
217218
return error
218219
try:
219-
values = await self._get_values(request, kw) # type: ignore
220+
temporal_response = self.api.create_temporal_response(request)
221+
values = await self._get_values(request, kw, temporal_response) # type: ignore
220222
result = await self.view_func(request, **values)
221-
_processed_results = await self._result_to_response(request, result) # type: ignore
223+
_processed_results = await self._result_to_response(request, result, temporal_response) # type: ignore
222224
return cast(HttpResponseBase, _processed_results)
223225
except Exception as e:
224226
return self.api.on_exception(request, e)
@@ -262,7 +264,8 @@ async def run(self, request: HttpRequest, **kw: Any) -> HttpResponseBase: # typ
262264
return error
263265
try:
264266
async with self._prep_run(request, **kw) as ctx:
265-
values = await self._get_values(request, kw) # type: ignore
267+
temporal_response = self.api.create_temporal_response(request)
268+
values = await self._get_values(request, kw, temporal_response) # type: ignore
266269
ctx.kwargs = values
267270
result = await self.view_func(context=ctx, **values)
268271
_processed_results = await self._result_to_response(request, result) # type: ignore

0 commit comments

Comments
 (0)