examples/src/python/BUILD

package(default_visibility = ["//visibility:public"])

load("@rules_python//python:defs.bzl", "py_library")
load("@rules_python//python:defs.bzl", "py_binary")

py_library(
    name = "example-py",
    srcs = glob([
        "bolt/*.py",
        "spout/*.py",
        "misc/*.py",
    ]),
    deps = [
        "//heronpy/api:heron-python-py",
    ],
)

# with main method
py_binary(
    name = "word_count",
    srcs = ["word_count_topology.py"],
    deps = [":example-py"],
)

py_binary(
    name = "half_acking",
    srcs = ["half_acking_topology.py"],
    deps = [":example-py"],
)

py_binary(
    name = "window_size",
    srcs = ["window_size_topology.py"],
    deps = [":example-py"],
)

py_binary(
    name = "stateful_word_count",
    srcs = ["stateful_word_count_topology.py"],
    deps = [":example-py"],
)

# without main method
py_binary(
    name = "custom_grouping",
    srcs = ["custom_grouping_topology.py"],
    deps = [":example-py"],
)

py_binary(
    name = "multi_stream",
    srcs = ["multi_stream_topology.py"],
    deps = [":example-py"],
)

# streamlet API examples
py_binary(
    name = "word_count_streamlet",
    srcs = ["word_count_streamlet.py"],
    deps = [
        "//heronpy/api:heron-python-py",
        "//heronpy/connectors:heron-pythonconnectors-py",
        "//heronpy/streamlet:heron-python-streamlet-py",
    ],
)

py_binary(
    name = "pulsar_word_count_streamlet",
    srcs = ["pulsar_word_count_streamlet.py"],
    deps = [
        "//heronpy/api:heron-python-py",
        "//heronpy/connectors:heron-pythonconnectors-py",
        "//heronpy/streamlet:heron-python-streamlet-py",
    ],
)

py_binary(
    name = "join_streamlet_topology",
    srcs = ["join_streamlet_topology.py"],
    deps = [
        "//heronpy/api:heron-python-py",
        "//heronpy/connectors:heron-pythonconnectors-py",
        "//heronpy/streamlet:heron-python-streamlet-py",
    ],
)