diff --git a/ee/api/chalicelib/utils/events_queue.py b/ee/api/chalicelib/utils/events_queue.py index 8a002a8cf..a1a475d39 100644 --- a/ee/api/chalicelib/utils/events_queue.py +++ b/ee/api/chalicelib/utils/events_queue.py @@ -35,7 +35,7 @@ class EventQueue(): def force_flush(self): if not self.events.empty(): - with pg_client.PostgreClient() as conn: + with pg_client.PostgresClient() as conn: self.flush(conn) def put(self, element): diff --git a/ee/api/routers/core_dynamic.py b/ee/api/routers/core_dynamic.py index a1e9734c4..3250df394 100644 --- a/ee/api/routers/core_dynamic.py +++ b/ee/api/routers/core_dynamic.py @@ -438,7 +438,7 @@ def get_all_notes(projectId: int, data: schemas.SearchNoteSchema = Body(...), @app.post('/{projectId}/signals', tags=['signals']) -def send_interactions(data: schemas_ee.SignalsSchema = Body(...), +def send_interactions(projectId:int, data: schemas_ee.SignalsSchema = Body(...), context: schemas.CurrentContext = Depends(OR_context)): data = signals.handle_frontend_signals(project_id=projectId, user_id=context.user_id, data=data)