@ -25,6 +25,12 @@ class Ingest(object):
def __init__(self):
name = self.__class__.__name__
self.log = util.get_logger(name)
self.log.info(
(
"Starting ingest handler for chunk size of "
f"{CHUNK_SIZE} every {ITER_DELAY} seconds."
)
async def run(self):
while True: