scystream-sdk 0.1.4

The official SDK for developing scystream compute blocks

scystream-sdk

Installation

You can install the package via pip once it's published:

pip install scystream-sdk

Usage

from scystream.sdk.core import entrypoint
from scystream.sdk.scheduler import Scheduler


@entrypoint
def example_task():
    print("Executing example_task...")


@entrypoint
def another_task(task_name):
    print(f"Executing another_task with task name: {task_name}")


def main():
    Scheduler.list_entrypoints()
    Scheduler.execute_function("example_task")
    Scheduler.execute_function("another_task", "ScheduledTask")


if __name__ == "__main__":
    main()