Refactor wkk job.py for improved readability and logging

m3nowak · Oct 10, 2024 · 3c85852 · 3c85852
1 parent 8485efc
commit 3c85852
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/src/rg_app/wkk/job.py b/src/rg_app/wkk/job.py
@@ -66,10 +66,12 @@ def extract_form_token(html: bytes) -> str:
 
 async def main(config: Config):
     nc = await nats_connect(
-        config.nats.url, user_credentials=config.nats.creds_path, inbox_prefix=config.nats.inbox_prefix
+        config.nats.url,
+        user_credentials=config.nats.creds_path,
+        inbox_prefix=config.nats.inbox_prefix,
     )
     js = nc.jetstream(domain=config.nats.js_domain)
-
+    logging.info(f"Connected to NATS at {config.nats.url}")
     sa_engine = create_async_engine(
         config.db.get_url(),
     )