From 0a4904287d50cd41751f1d2957a01d85e3a392e3 Mon Sep 17 00:00:00 2001 From: Tom Most Date: Sun, 30 Apr 2023 16:01:52 -0700 Subject: [PATCH] Quote Deferred annotations --- src/treq/multipart.py | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/src/treq/multipart.py b/src/treq/multipart.py index 8bb10219..56becbfa 100644 --- a/src/treq/multipart.py +++ b/src/treq/multipart.py @@ -83,7 +83,7 @@ def __init__( self.length = self._calculateLength() - def startProducing(self, consumer: IConsumer) -> Deferred[None]: + def startProducing(self, consumer: IConsumer) -> "Deferred[None]": """ Start a cooperative task which will read bytes from the input file and write them to `consumer`. Return a `Deferred` which fires after all @@ -94,13 +94,13 @@ def startProducing(self, consumer: IConsumer) -> Deferred[None]: self._task = self._cooperate(self._writeLoop(consumer)) # type: ignore # whenDone returns the iterator that was passed to cooperate, so who # cares what type it has? It's an edge signal; we ignore its value. - d: Deferred[Any] = self._task.whenDone() + d: "Deferred[Any]" = self._task.whenDone() - def maybeStopped(reason: Failure) -> Deferred: + def maybeStopped(reason: Failure) -> "Deferred[None]": reason.trap(task.TaskStopped) return Deferred() - d = cast(Deferred[None], d.addCallbacks(lambda ignored: None, maybeStopped)) + d = cast("Deferred[None]", d.addCallbacks(lambda ignored: None, maybeStopped)) return d def stopProducing(self) -> None: @@ -215,7 +215,7 @@ def _writeFile( content_type: str, producer: IBodyProducer, consumer: _Consumer, - ) -> Optional[Deferred[None]]: + ) -> "Optional[Deferred[None]]": cdisp = _Header(b"Content-Disposition", b"form-data") cdisp.add_param(b"name", name) if filename: @@ -240,7 +240,7 @@ def unset(val): return val d = producer.startProducing(consumer) - return cast(Deferred[None], d.addCallback(unset)) + return cast("Deferred[None]", d.addCallback(unset)) def _escape(value: Union[str, bytes]) -> str: