LICENSE
README.md
pyproject.toml
src/isage.egg-info/PKG-INFO
src/isage.egg-info/SOURCES.txt
src/isage.egg-info/dependency_links.txt
src/isage.egg-info/entry_points.txt
src/isage.egg-info/requires.txt
src/isage.egg-info/top_level.txt
src/sage/_version.py
src/sage/cli/__init__.py
src/sage/cli/main.py
src/sage/cli/commands/__init__.py
src/sage/cli/commands/apps/__init__.py
src/sage/cli/commands/apps/chat.py
src/sage/edge/__init__.py
src/sage/edge/_version.py
src/sage/edge/app.py
src/sage/edge/core.py
src/sage/edge/server.py
src/sage/foundation/__init__.py
src/sage/foundation/core.py
src/sage/foundation/debug.py
src/sage/foundation/logging.py
src/sage/foundation/config/__init__.py
src/sage/foundation/config/ports.py
src/sage/foundation/config/user_paths.py
src/sage/foundation/model_registry/__init__.py
src/sage/foundation/model_registry/sagellm_registry.py
src/sage/runtime/__init__.py
src/sage/runtime/actor_wrappers.py
src/sage/runtime/backend.py
src/sage/runtime/backend_protocol.py
src/sage/runtime/base_environment.py
src/sage/runtime/base_tcp_client.py
src/sage/runtime/batch_functions.py
src/sage/runtime/context_injection.py
src/sage/runtime/environments.py
src/sage/runtime/exception_hooks.py
src/sage/runtime/flownet_backend.py
src/sage/runtime/job_manager.py
src/sage/runtime/jobmanager_client.py
src/sage/runtime/local_backend.py
src/sage/runtime/pipeline_compiler.py
src/sage/runtime/scheduler.py
src/sage/runtime/service.py
src/sage/runtime/service_factory.py
src/sage/runtime/flownet/__init__.py
src/sage/runtime/flownet/__main__.py
src/sage/runtime/flownet/cli.py
src/sage/runtime/flownet/api/__init__.py
src/sage/runtime/flownet/api/declarations.py
src/sage/runtime/flownet/api/decorators.py
src/sage/runtime/flownet/api/flow_exception_handlers.py
src/sage/runtime/flownet/client/__init__.py
src/sage/runtime/flownet/client/bootstrap.py
src/sage/runtime/flownet/client/cluster_context.py
src/sage/runtime/flownet/client/dataset_job.py
src/sage/runtime/flownet/client/handles.py
src/sage/runtime/flownet/client/inspect.py
src/sage/runtime/flownet/client/node_runtime.py
src/sage/runtime/flownet/client/registries.py
src/sage/runtime/flownet/client/runtime_client.py
src/sage/runtime/flownet/client/session.py
src/sage/runtime/flownet/compiler/__init__.py
src/sage/runtime/flownet/compiler/errors.py
src/sage/runtime/flownet/compiler/exception_scope.py
src/sage/runtime/flownet/compiler/flow_compiler.py
src/sage/runtime/flownet/compiler/streams.py
src/sage/runtime/flownet/compiler/targets.py
src/sage/runtime/flownet/compiler/transformation.py
src/sage/runtime/flownet/contracts/__init__.py
src/sage/runtime/flownet/contracts/endpoint_plane_contract.py
src/sage/runtime/flownet/contracts/flow_program_submit_contract.py
src/sage/runtime/flownet/contracts/flow_run_observation_contract.py
src/sage/runtime/flownet/contracts/recovery_contract.py
src/sage/runtime/flownet/contracts/runtime_state_query_contract.py
src/sage/runtime/flownet/contracts/runtime_telemetry_contract.py
src/sage/runtime/flownet/contracts/shared_state_contract.py
src/sage/runtime/flownet/core/__init__.py
src/sage/runtime/flownet/core/flow_program.py
src/sage/runtime/flownet/data/__init__.py
src/sage/runtime/flownet/data/connectors/__init__.py
src/sage/runtime/flownet/data/connectors/checkpoints.py
src/sage/runtime/flownet/data/connectors/core.py
src/sage/runtime/flownet/integrations/__init__.py
src/sage/runtime/flownet/node/__init__.py
src/sage/runtime/flownet/node/cli.py
src/sage/runtime/flownet/node/cluster_inventory.py
src/sage/runtime/flownet/node/cluster_reconcile.py
src/sage/runtime/flownet/node/cluster_target.py
src/sage/runtime/flownet/runtime/__init__.py
src/sage/runtime/flownet/runtime/endpoint_registry.py
src/sage/runtime/flownet/runtime/governance.py
src/sage/runtime/flownet/runtime/loops.py
src/sage/runtime/flownet/runtime/runtime.py
src/sage/runtime/flownet/runtime/shared_state_registry.py
src/sage/runtime/flownet/runtime/actors/__init__.py
src/sage/runtime/flownet/runtime/actors/actor_api.py
src/sage/runtime/flownet/runtime/actors/backend_jobs.py
src/sage/runtime/flownet/runtime/actors/callback_handle.py
src/sage/runtime/flownet/runtime/actors/callback_registry.py
src/sage/runtime/flownet/runtime/actors/comm_bridge.py
src/sage/runtime/flownet/runtime/actors/error_codes.py
src/sage/runtime/flownet/runtime/actors/event_emitter.py
src/sage/runtime/flownet/runtime/actors/execution_context.py
src/sage/runtime/flownet/runtime/actors/executor_lanes.py
src/sage/runtime/flownet/runtime/actors/invoker.py
src/sage/runtime/flownet/runtime/actors/registry.py
src/sage/runtime/flownet/runtime/actors/task_runtime.py
src/sage/runtime/flownet/runtime/backend_container/__init__.py
src/sage/runtime/flownet/runtime/backend_container/contracts.py
src/sage/runtime/flownet/runtime/backend_container/registry.py
src/sage/runtime/flownet/runtime/collective/__init__.py
src/sage/runtime/flownet/runtime/collective/contracts.py
src/sage/runtime/flownet/runtime/collective/dispatch.py
src/sage/runtime/flownet/runtime/collective/executors.py
src/sage/runtime/flownet/runtime/collective/registry.py
src/sage/runtime/flownet/runtime/comm/__init__.py
src/sage/runtime/flownet/runtime/comm/backends.py
src/sage/runtime/flownet/runtime/comm/hub.py
src/sage/runtime/flownet/runtime/comm/loopback.py
src/sage/runtime/flownet/runtime/comm/protocol.py
src/sage/runtime/flownet/runtime/comm/reply_tracker.py
src/sage/runtime/flownet/runtime/comm/router.py
src/sage/runtime/flownet/runtime/comm/transport.py
src/sage/runtime/flownet/runtime/flowengine/__init__.py
src/sage/runtime/flownet/runtime/flowengine/actor_cursor_invoker.py
src/sage/runtime/flownet/runtime/flowengine/cursor_codec.py
src/sage/runtime/flownet/runtime/flowengine/cursor_ctx.py
src/sage/runtime/flownet/runtime/flowengine/cursor_guards.py
src/sage/runtime/flownet/runtime/flowengine/cursor_models.py
src/sage/runtime/flownet/runtime/flowengine/engine.py
src/sage/runtime/flownet/runtime/flowengine/exception_decision.py
src/sage/runtime/flownet/runtime/flowengine/exception_runner.py
src/sage/runtime/flownet/runtime/flowengine/flow_process_execution.py
src/sage/runtime/flownet/runtime/flowengine/loop_ctx.py
src/sage/runtime/flownet/runtime/flowengine/operator_executor.py
src/sage/runtime/flownet/runtime/flowengine/operator_runtime.py
src/sage/runtime/flownet/runtime/flowengine/program_cache.py
src/sage/runtime/flownet/runtime/flowengine/program_comm_bridge.py
src/sage/runtime/flownet/runtime/flowengine/scope_resolver.py
src/sage/runtime/flownet/runtime/operator_runtime/__init__.py
src/sage/runtime/flownet/runtime/operator_runtime/collective.py
src/sage/runtime/flownet/runtime/operator_runtime/dispatch.py
src/sage/runtime/flownet/runtime/operator_runtime/errors.py
src/sage/runtime/flownet/runtime/operator_runtime/flatmap.py
src/sage/runtime/flownet/runtime/operator_runtime/loop.py
src/sage/runtime/flownet/runtime/operator_runtime/models.py
src/sage/runtime/flownet/runtime/operator_runtime/process_ref.py
src/sage/runtime/flownet/runtime/operator_runtime/protocols.py
src/sage/runtime/flownet/runtime/operator_runtime/reducers.py
src/sage/runtime/flownet/runtime/operator_runtime/routing.py
src/sage/runtime/flownet/runtime/operator_runtime/stateful.py
src/sage/runtime/flownet/runtime/operator_runtime/utils.py
src/sage/runtime/flownet/runtime/topics/__init__.py
src/sage/runtime/flownet/runtime/topics/comm_bridge.py
src/sage/runtime/flownet/runtime/topics/control_dispatch.py
src/sage/runtime/flownet/runtime/topics/coordinator_registry.py
src/sage/runtime/flownet/runtime/topics/event_dispatch.py
src/sage/runtime/flownet/runtime/topics/event_group_ledger.py
src/sage/runtime/flownet/runtime/topics/exception_invoker.py
src/sage/runtime/flownet/runtime/topics/flow_process_catalog.py
src/sage/runtime/flownet/runtime/topics/normalization.py
src/sage/runtime/flownet/runtime/topics/routing_directory.py
src/sage/runtime/flownet/runtime/topics/subscriber_progress.py
src/sage/runtime/flownet/runtime/topics/subscriber_registry.py
src/sage/runtime/flownet/runtime/topics/topic_api.py
src/sage/serving/__init__.py
src/sage/serving/gateway.py
src/sage/serving/integrations/__init__.py
src/sage/serving/integrations/contracts.py
src/sage/serving/integrations/mock.py
src/sage/serving/integrations/registry.py
src/sage/stream/__init__.py
src/sage/stream/_kernel_bindings.py
src/sage/stream/_kernel_runtime.py
src/sage/stream/_runtime_kernel_types.py
src/sage/stream/connected_streams.py
src/sage/stream/datastream.py
src/sage/stream/factories.py
src/sage/stream/operators.py
src/sage/stream/transformations.py
src/sage/tools/cli/commands/dev.py
src/tests/test_benchmark_carrier_stub.py
src/tests/test_cli_main.py
src/tests/test_edge_app.py
src/tests/test_edge_core.py
src/tests/test_edge_server.py
src/tests/test_flownet_backend_container_plane_contract.py
src/tests/test_flownet_collective_executor_contract.py
src/tests/test_flownet_connector_checkpoint_fault_tolerance.py
src/tests/test_flownet_endpoint_plane_contract.py
src/tests/test_flownet_runtime_state_query.py
src/tests/test_flownet_service_lifecycle_runner.py
src/tests/test_flownet_shared_state_service_contract.py
src/tests/test_openai_replay_carrier.py
src/tests/test_runtime_local_consolidation.py
src/tests/test_runtime_parallelism_contract.py
src/tests/test_vamos_launcher_contract_runner.py
src/tests/test_workflow_product_integration_contract.py