From 37335275c87d71e5ee4a89fca69b0de0f83765a7 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Sybren=20A=2E=20St=C3=BCvel?= <sybren@stuvel.eu>
Date: Fri, 31 Mar 2017 15:21:10 +0200
Subject: [PATCH] Fixed type annotation
---
flamenco_worker/upstream_update_queue.py | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/flamenco_worker/upstream_update_queue.py b/flamenco_worker/upstream_update_queue.py
index bffe3d6f..f9aac794 100644
--- a/flamenco_worker/upstream_update_queue.py
+++ b/flamenco_worker/upstream_update_queue.py
@@ -7,6 +7,7 @@ for efficient conversion of Python objects into a binary data blob.
import asyncio
import pickle
import sqlite3
+import typing
import attr
@@ -90,7 +91,7 @@ class TaskUpdateQueue:
await self.flush_and_catch(loop=loop)
self._log.warning('Stopping work loop')
- def _queue(self) -> (int, str, object):
+ def _queue(self) -> typing.Iterable[typing.Tuple[int, str, object]]:
"""Yields (rowid, url, unpickled payload) tuples from the database."""
if self._db is None:
--
GitLab