@@ -155,10 +155,13 @@ 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 (
163+ request , result , temporal_response
164+ )
162165 return _processed_results
163166 except Exception as e :
164167 if isinstance (e , TypeError ) and "required positional argument" in str (e ):
@@ -216,9 +219,10 @@ async def run(self, request: HttpRequest, **kw: Any) -> HttpResponseBase: # typ
216219 if error :
217220 return error
218221 try :
219- values = await self ._get_values (request , kw ) # type: ignore
222+ temporal_response = self .api .create_temporal_response (request )
223+ values = await self ._get_values (request , kw , temporal_response ) # type: ignore
220224 result = await self .view_func (request , ** values )
221- _processed_results = await self ._result_to_response (request , result ) # type: ignore
225+ _processed_results = await self ._result_to_response (request , result , temporal_response ) # type: ignore
222226 return cast (HttpResponseBase , _processed_results )
223227 except Exception as e :
224228 return self .api .on_exception (request , e )
@@ -262,20 +266,21 @@ async def run(self, request: HttpRequest, **kw: Any) -> HttpResponseBase: # typ
262266 return error
263267 try :
264268 async with self ._prep_run (request , ** kw ) as ctx :
265- values = await self ._get_values (request , kw ) # type: ignore
269+ temporal_response = self .api .create_temporal_response (request )
270+ values = await self ._get_values (request , kw , temporal_response ) # type: ignore
266271 ctx .kwargs = values
267272 result = await self .view_func (context = ctx , ** values )
268- _processed_results = await self ._result_to_response (request , result ) # type: ignore
273+ _processed_results = await self ._result_to_response (request , result , temporal_response ) # type: ignore
269274 return cast (HttpResponseBase , _processed_results )
270275 except Exception as e :
271276 return self .api .on_exception (request , e )
272277
273278
274279class PathView (NinjaPathView ):
275- async def _async_view (self , request : HttpRequest , * args , ** kwargs ) -> HttpResponse : # type: ignore
280+ async def _async_view (self , request : HttpRequest , * args , ** kwargs ) -> HttpResponseBase : # type: ignore
276281 return await super (PathView , self )._async_view (request , * args , ** kwargs )
277282
278- def _sync_view (self , request : HttpRequest , * args , ** kwargs ) -> HttpResponse : # type: ignore
283+ def _sync_view (self , request : HttpRequest , * args , ** kwargs ) -> HttpResponseBase : # type: ignore
279284 return super (PathView , self )._sync_view (request , * args , ** kwargs )
280285
281286 def add_operation (
0 commit comments