diff --git a/flatsurvey/worker/worker.py b/flatsurvey/worker/worker.py index f5bcae4..afd4803 100644 --- a/flatsurvey/worker/worker.py +++ b/flatsurvey/worker/worker.py @@ -214,7 +214,6 @@ async def start(self): r""" Run until all our goals are resolved. """ - assert self._goals try: for goal in self._goals: await goal.consume_cache() @@ -223,5 +222,6 @@ async def start(self): finally: for goal in self._goals: await goal.report() + for reporter in self._reporters: reporter.flush()