scystream.sdk package#

Subpackages#

Submodules#

scystream.sdk.core module#

scystream.sdk.core.entrypoint(settings_class: Type[EnvSettings] | None = None)[source]#

Decorator to mark a function as an entrypoint. It also loads and injects the settings of the entrypoint.

scystream.sdk.scheduler module#

class scystream.sdk.scheduler.Scheduler[source]#

Bases: object

static execute_function(name, *args, **kwargs)[source]#

Validate the in code defined entrypoints with the settings defined in the cfg file

static list_entrypoints()[source]#

List all registered entrypoint functions.

scystream.sdk.spark_manager module#

class scystream.sdk.spark_manager.SparkManager[source]#

Bases: object

__init__()[source]#
setup_pg(config: PostgresConfig)[source]#
stop_session()[source]#