Fix consumer sleep.
Signed-off-by: Jan Losinski <losinski@wh2.tu-dresden.de>
This commit is contained in:
parent
526817de61
commit
6eaeb17a31
|
|
@ -42,5 +42,5 @@ class Consumer:
|
||||||
await asyncio.gather(*jobs)
|
await asyncio.gather(*jobs)
|
||||||
self.session.commit()
|
self.session.commit()
|
||||||
|
|
||||||
asyncio.sleep(self.interval)
|
await asyncio.sleep(self.interval)
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue