Skip to content

Commit

Permalink
more logging
Browse files Browse the repository at this point in the history
  • Loading branch information
meln1k committed Nov 16, 2023
1 parent 7d89d49 commit 3fd7184
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
4 changes: 2 additions & 2 deletions fixbackend/cloud_accounts/account_setup.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@

from abc import ABC
import logging
from typing import Optional, Dict
from typing import Optional, Dict, Any
from fixcloudutils.asyncio.async_extensions import run_async
from fixbackend.ids import ExternalId, CloudAccountAlias, CloudAccountName
from attrs import frozen
Expand Down Expand Up @@ -84,7 +84,7 @@ async def list_accounts(
next_token = None
try:
while True:
kwargs = {}
kwargs: Dict[str, Any] = {}
if next_token:
kwargs["NextToken"] = next_token
response = await run_async(
Expand Down
2 changes: 1 addition & 1 deletion fixbackend/domain_events/subscriber.py
Original file line number Diff line number Diff line change
Expand Up @@ -93,7 +93,7 @@ async def timed(self, callback: Callback[Evt], event: Evt) -> None:
async def process_domain_event(self, message: Json, context: MessageContext) -> None:
log.info(f"Processing domain event: {message} {context}")
handler = self.subscribers.get(context.kind)
log.info(f"Handler: {handler}")
log.info(f"subscribers: {self.subscribers} Handler: {handler}")
if not handler:
return
event = handler.event_cls.from_json(message)
Expand Down

0 comments on commit 3fd7184

Please sign in to comment.