Logging

allenai · Nov 14, 2024 · 9a1e82f · 9a1e82f
1 parent fe0574c
commit 9a1e82f
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/pdelfin/beakerpipeline.py b/pdelfin/beakerpipeline.py
@@ -69,7 +69,7 @@
 # Process pool for offloading cpu bound work, like calculating anchor texts
 process_pool = ProcessPoolExecutor()
 
-SGLANG_SERVER_PORT = 30003
+SGLANG_SERVER_PORT = 30002
 
 @dataclass(frozen=True)
 class PageResult:
@@ -429,6 +429,8 @@ async def worker(args, queue, semaphore, worker_id):
             if await work_item_completed(args, work_hash):
                 logger.info(f"Work {work_hash} was already completed, skipping")
                 continue
+            else:
+                logger.info(f"Proceeding with {work_hash} on worker {worker_id}")
 
             async with aiohttp.ClientSession(timeout=aiohttp.ClientTimeout(total=3600), 
                                              connector=aiohttp.TCPConnector(limit=1000)) as session:

diff --git a/pdelfin/version.py b/pdelfin/version.py
@@ -2,7 +2,7 @@
 _MINOR = "1"
 # On main and in a nightly release the patch should be one ahead of the last
 # released build.
-_PATCH = "13"
+_PATCH = "14"
 # This is mainly for nightly builds which have the suffix ".dev$DATE". See
 # https://semver.org/#is-v123-a-semantic-version for the semantics.
 _SUFFIX = ""