From 299d2f04d31b1d1ee18cbe3be03303d959173340 Mon Sep 17 00:00:00 2001 From: Max Novelli Date: Mon, 3 Jun 2024 14:00:05 +0200 Subject: [PATCH] fixed linting and syntax --- src/scicat_ingestor.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/scicat_ingestor.py b/src/scicat_ingestor.py index 524ea33..64d1ba5 100644 --- a/src/scicat_ingestor.py +++ b/src/scicat_ingestor.py @@ -56,7 +56,6 @@ def main() -> None: # check if we have received a WRDN message # if message is not a WRDN, we get None back if message: - # extract nexus file name from message # extract job id from message @@ -66,7 +65,8 @@ def main() -> None: # instantiate a new process and runs backeground ingestor # on the nexus file + pass + # check if we need to commit the individual message if config.kafka_options.individual_message_commit: consumer.commit(message=message) - \ No newline at end of file