Skip to content

Commit d80cb4b

Browse files
committed
update dispatcher logging
1 parent a857ca7 commit d80cb4b

File tree

1 file changed

+2
-2
lines changed
  • functions-python/feed_sync_dispatcher_transitland/src

1 file changed

+2
-2
lines changed

functions-python/feed_sync_dispatcher_transitland/src/main.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@
3232
from shared.helpers.feed_sync.feed_sync_common import FeedSyncProcessor, FeedSyncPayload
3333
from shared.helpers.feed_sync.feed_sync_dispatcher import feed_sync_dispatcher
3434
from shared.helpers.feed_sync.models import TransitFeedSyncPayload
35-
from shared.helpers.logger import Logger
35+
from shared.helpers.logger import init_logger
3636
from shared.helpers.pub_sub import get_pubsub_client, get_execution_id
3737
from typing import Tuple, List
3838
from collections import defaultdict
@@ -47,6 +47,7 @@
4747

4848
# session instance to reuse connections
4949
session = requests.Session()
50+
init_logger()
5051

5152

5253
def process_feed_urls(feed: dict, urls_in_db: List[str]) -> Tuple[List[str], List[str]]:
@@ -388,7 +389,6 @@ def feed_sync_dispatcher_transitland(request):
388389
"""
389390
HTTP Function entry point queries the transitland API and publishes events to a Pub/Sub topic to be processed.
390391
"""
391-
Logger.init_logger()
392392
publisher = get_pubsub_client()
393393
topic_path = publisher.topic_path(PROJECT_ID, PUBSUB_TOPIC_NAME)
394394
transit_land_feed_sync_processor = TransitFeedSyncProcessor()

0 commit comments

Comments
 (0)