nemo_curator.core.serve.dynamo.constants

Module Contents

Data

DEFAULT_DYNAMO_EVENT_PLANE

DEFAULT_DYNAMO_NAMESPACE

DEFAULT_DYNAMO_REQUEST_PLANE

DEFAULT_ETCD_PORT

DEFAULT_NATS_PORT

ETCD_ACTOR_LABEL

FRONTEND_ACTOR_LABEL

INFRA_ETCD_BUNDLE

INFRA_FRONTEND_BUNDLE

INFRA_NATS_BUNDLE

INFRA_NUM_BUNDLES

NATS_ACTOR_LABEL

NEMO_CURATOR_DYNAMO_NAMESPACE

API

nemo_curator.core.serve.dynamo.constants.DEFAULT_DYNAMO_EVENT_PLANE = 'nats'

nemo_curator.core.serve.dynamo.constants.DEFAULT_DYNAMO_NAMESPACE = 'curator'

nemo_curator.core.serve.dynamo.constants.DEFAULT_DYNAMO_REQUEST_PLANE = 'nats'

nemo_curator.core.serve.dynamo.constants.DEFAULT_ETCD_PORT = 2379

nemo_curator.core.serve.dynamo.constants.DEFAULT_NATS_PORT = 4222

nemo_curator.core.serve.dynamo.constants.ETCD_ACTOR_LABEL = 'Dynamo_ETCD'

nemo_curator.core.serve.dynamo.constants.FRONTEND_ACTOR_LABEL = 'Dynamo_Frontend'

nemo_curator.core.serve.dynamo.constants.INFRA_ETCD_BUNDLE = 0

nemo_curator.core.serve.dynamo.constants.INFRA_FRONTEND_BUNDLE = 2

nemo_curator.core.serve.dynamo.constants.INFRA_NATS_BUNDLE = 1

nemo_curator.core.serve.dynamo.constants.INFRA_NUM_BUNDLES = 3

nemo_curator.core.serve.dynamo.constants.NATS_ACTOR_LABEL = 'Dynamo_NATS'

nemo_curator.core.serve.dynamo.constants.NEMO_CURATOR_DYNAMO_NAMESPACE = 'nemo_curator_dynamo'

Ray namespace used for all Dynamo-related detached actors and placement groups.

Passed as namespace= in ray.init() from DynamoBackend.start() and .stop(). Pipeline executors (Xenna, Ray Data) use their own namespace, so there is no collision. Keeping the PGs + actors in a stable namespace lets a reconnecting driver (server.start -> pipeline.run -> server.stop) find and reap them across ray.shutdown() / ray.init() cycles.