dora/examples/python-dataflow/control_node.py

#!/usr/bin/env python
# -*- coding: utf-8 -*-

import random
from dora import Node
import pyarrow as pa

node = Node()

for event in node:
    if event["type"] == "INPUT":
        print(
            f"""Node received:
    id: {event["id"]},
    value: {event["data"]},
    metadata: {event["metadata"]}"""
        )
        node.send_output(
            "direction",
            pa.array(
                [random.random() + 1, 0, 0, 0, 0, random.random() - 0.5],
                type=pa.uint8(),
            ),
        )