Browse Source

Add time limit for test of 10s

tags/v0.3.10-rc0
haixuantao 11 months ago
parent
commit
3fca6f9e2c
1 changed files with 3 additions and 1 deletions
  1. +3
    -1
      tests/queue_size_and_timeout_python/send_data.py

+ 3
- 1
tests/queue_size_and_timeout_python/send_data.py View File

@@ -3,11 +3,13 @@ import time
import pyarrow as pa
from dora import Node

start = time.time()


def main() -> None:
dora_node = Node()
i = 0
while True:
while time.time() - start < 10:
dora_node.send_output("ts", pa.array([time.perf_counter_ns(), i]))
i += 1
# print(f"Sent {i} times", flush=True)


Loading…
Cancel
Save