project.pool() | project.service() | service.pipeline()Pool, Service, and Pipeline
Execution capacity, deployment boundary, and stream namespace objects.
When to use
Create pools and services at project scope, then create streams through a named Pipeline.
Behavior
- Pool controls executors and optional queue capacity for task-pool links.
- Service stores language, listener, lifecycle, deployment, and default call-semantic settings.
- Pipeline is a named stream registry inside one Service and exposes concrete stream factories.
project.pool() properties
Task pool factory.
namestrPool name and derived key.
Requiredexecutors_countintNumber of concurrent executors.
Requiredqueue_capacityint | NoneOptional bounded queue capacity.
Default:Noneproject.service() properties
Service factory and common generated defaults.
namestrService name and directory identity.
Requiredprogramming_languageProgrammingLanguageTarget runtime language.
Requiredmodule_pathstrService package/module identity.
Requireddefault_call_semanticsCallSemanticsSemantics used when a persisted link override is absent.
Default:FunctionCallhttp_host / http_portstr / intGenerated HTTP listener.
Default:0.0.0.0 / 8080grpc_host / grpc_portstr / intGenerated gRPC listener.
Default:0.0.0.0 / 9090default_grpc_timeoutintDefault gRPC timeout in milliseconds.
Default:30000shutdown_timeoutintTotal service shutdown timeout in milliseconds.
Default:30000kubernetes_workload_typeKubernetesWorkloadTypeGenerated Kubernetes workload kind.
Default:Deploymentstatus_handler / metrics_handlerstrStatus and metrics HTTP paths.
Default:status / metricsstartup_handler / readiness_handler / liveness_handlerstrKubernetes probe paths.
Default:health/startup, health/ready, health/liveservice.pipeline(name) properties
Named stream namespace.
namestrPipeline name and key.
Requiredstreamsdict[str, Stream]Streams registered by concrete factory methods.
Python example
workers = project.pool("Workers", executors_count=8, queue_capacity=1000)
service = project.service(
"Order Service",
programming_language=ProgrammingLanguage.GO,
module_path="github.com/example/orders/orderservice",
shutdown_timeout=45_000,
)
orders = service.pipeline("orders")