Skip to content

Commit

Permalink
chore: fix build
Browse files Browse the repository at this point in the history
  • Loading branch information
cbrzn committed Feb 18, 2024
1 parent cc3d6b4 commit bcebc39
Showing 1 changed file with 7 additions and 7 deletions.
14 changes: 7 additions & 7 deletions workers/fund_public_goods/events.py
Original file line number Diff line number Diff line change
@@ -1,16 +1,16 @@
from dataclasses import dataclass
from typing import Any
from typing import Any, Union
from aws_lambda_typing.events import SQSEvent
from fastapi_events.typing import Event as LocalEvent
from fastapi_events.handlers.local import local_handler
from fastapi_events.handlers.local import local_handler, BaseEventHandler
from fastapi_events.handlers.aws import SQSForwardHandler
from fastapi_events.middleware import EventHandlerASGIMiddleware
from fund_public_goods.lib.strategy.create import create
import os
import json
from fastapi import FastAPI

@dataclass(kw_only=True)
@dataclass
class EventData:
name: str
payload: dict[str, Any]
Expand All @@ -26,7 +26,7 @@ def handler(event: EventData):
@local_handler.register(event_name="*")
def local_handle(local_event: LocalEvent):
event_name, payload = local_event
event = EventData(name=event_name, payload=payload)
event = EventData(name=str(event_name), payload=payload)
handler(event)

def sqs_handler(sqs_event: SQSEvent):
Expand All @@ -36,15 +36,15 @@ def sqs_handler(sqs_event: SQSEvent):
message_body: str = record['body']
message: dict[str, Any] = json.loads(message_body)
events.append(EventData(
message["name"],
message["payload"]
name=message["name"],
payload=message["payload"]
))

for event in events:
handler(event)

def add_event_middleware(app: FastAPI):
event_handlers = []
event_handlers: list[BaseEventHandler] = []
env = os.getenv("RUNTIME")

if env == "cloud":
Expand Down

0 comments on commit bcebc39

Please sign in to comment.