diff --git a/src/writer_eventbridge.py b/src/writer_eventbridge.py index 1a9446d..fa6b353 100644 --- a/src/writer_eventbridge.py +++ b/src/writer_eventbridge.py @@ -14,7 +14,7 @@ def init(logger, CONFIG): _logger.debug("Initialized EVENTBRIDGE writer") def write(topicName, message): - if not aws_eventbridge: + if not EVENT_BUS_ARN: _logger.debug("No EventBus Arn - skipping") return True diff --git a/src/writer_postgres.py b/src/writer_postgres.py index cd56488..6d1d929 100644 --- a/src/writer_postgres.py +++ b/src/writer_postgres.py @@ -140,7 +140,7 @@ def postgres_run_write(cursor, table_runs, table_jobs, message): def write(topicName, message): try: if not POSTGRES["database"]: - _logger.debug("No Postgress - skipping") + _logger.debug("No Postgres - skipping") return with psycopg2.connect(