Skip to content
This repository was archived by the owner on Dec 5, 2025. It is now read-only.

Commit 037935b

Browse files
authored
[Client-python] Fix error with queue_threshold (#730)
1 parent 9f29f07 commit 037935b

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

pycti/connector/opencti_connector_helper.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -671,8 +671,8 @@ def __init__(
671671
self,
672672
run_and_terminate: bool = False,
673673
buffering: bool = False,
674-
queue_threshold: float = 500,
675-
queue_messages_size: float = 0,
674+
queue_threshold: float = 500.0,
675+
queue_messages_size: float = 0.0,
676676
next_run_datetime: datetime = None,
677677
last_run_datetime: datetime = None,
678678
):
@@ -1191,7 +1191,7 @@ def check_connector_buffering(self) -> bool:
11911191
connector_queue_details = connector_details["connector_queue_details"]
11921192

11931193
queue_messages_size_byte = connector_queue_details["messages_size"]
1194-
queue_threshold = self.connect_queue_threshold
1194+
queue_threshold = float(self.connect_queue_threshold)
11951195

11961196
# Convert queue_messages_size to Mo (decimal)
11971197
queue_messages_size_mo = queue_messages_size_byte / 1000000
@@ -1210,7 +1210,7 @@ def check_connector_buffering(self) -> bool:
12101210
self.connector_info.queue_messages_size = queue_messages_size_mo
12111211
self.connector_info.queue_threshold = queue_threshold
12121212

1213-
if float(queue_messages_size_mo) < float(queue_threshold):
1213+
if queue_messages_size_mo < queue_threshold:
12141214
# Set buffering
12151215
self.connector_info.buffering = False
12161216
return False

0 commit comments

Comments
 (0)