From 891c2e2c10dc3ac36d452e343e779de72068114f Mon Sep 17 00:00:00 2001 From: James Woglom Date: Mon, 7 Oct 2024 21:30:50 -0400 Subject: [PATCH] fix printf --- tconnectsync/sync/tandemsource/process.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/tconnectsync/sync/tandemsource/process.py b/tconnectsync/sync/tandemsource/process.py index d224833..e7c2504 100644 --- a/tconnectsync/sync/tandemsource/process.py +++ b/tconnectsync/sync/tandemsource/process.py @@ -82,7 +82,9 @@ def process(self, time_start, time_end): if c.enabled(): logger.info("%s is enabled from features %s" % (clazz, self.features)) ns_entries = c.process(events, events_first_time, events_last_time) - processed_count += c.write(ns_entries) + w = c.write(ns_entries) + if w: + processed_count += w else: logger.info("Skipping %s, is not enabled from features %s" % (clazz, self.features)) @@ -95,6 +97,6 @@ def process(self, time_start, time_end): else: logger.info("Skipping %s, is not enabled from features %s" % (updater_class.__name__, self.features)) - logger.info("Processed %d events. Last event ID seen: %d" % (processed_count, last_event_id)) + logger.info("Processed %d events. Last event ID seen: %d" % (processed_count if processed_count else 0, last_event_id if last_event_id else -1)) return processed_count, last_event_id