Skip to content

Commit 3a9b429

Browse files
authored
fix suspension check error
1 parent f30492c commit 3a9b429

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/astroidapi/queue_processor.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -76,7 +76,7 @@ async def clearLoadedMessage(cls, endpoint, message):
7676

7777
@classmethod
7878
async def appendMessage(cls, endpoint, updated_json):
79-
is_suspend = await surrealdb_handler.Suspension.Endpoints.get_suspend_status(endpoint)
79+
is_suspend = await surrealdb_handler.Suspension.get_suspend_status(endpoint)
8080
if is_suspend["suspended"]:
8181
print(f"Endpoint {endpoint} is suspended. Not appending message.")
8282
return False
@@ -134,4 +134,4 @@ async def handleUpdatedEndpointData(cls, endpoint, updated_json):
134134
asyncio.create_task(cls.sendMessage(endpoint))
135135
print("Appended message to queue and sent.")
136136
else:
137-
print("Failed to append message to queue.")
137+
print("Failed to append message to queue.")

0 commit comments

Comments
 (0)