LICENSE
README.md
pyproject.toml
examples/base_server/__init__.py
examples/base_server/server_async_insecure.py
examples/base_server/server_async_secure.py
examples/base_server/server_sync_insecure.py
examples/base_server/server_sync_secure.py
examples/base_server/mock/__init__.py
examples/base_server/mock/mock_pb2.py
examples/base_server/mock/mock_pb2_grpc.py
examples/bench_module/__init__.py
examples/bench_module/echo_module.py
examples/bench_module/server.py
examples/bench_module/models/__init__.py
examples/bench_module/models/input.py
examples/bench_module/models/output.py
examples/bench_module/models/secret.py
examples/bench_module/models/setup.py
examples/bench_module/triggers/__init__.py
examples/bench_module/triggers/message_trigger.py
examples/modules/__init__.py
examples/modules/archetype_with_tools_module.py
examples/modules/cpu_intensive_module.py
examples/modules/dynamic_setup_module.py
examples/modules/minimal_llm_module.py
examples/modules/text_transform_module.py
examples/monitoring/digitalkin_observability/__init__.py
examples/monitoring/digitalkin_observability/http_server.py
examples/monitoring/digitalkin_observability/interceptors.py
examples/monitoring/digitalkin_observability/metrics.py
examples/monitoring/digitalkin_observability/prometheus.py
examples/monitoring/tests/test_metrics.py
examples/redis_demo/client.py
examples/redis_demo/echo_module.py
examples/redis_demo/server.py
examples/redis_demo/models/__init__.py
examples/redis_demo/models/input.py
examples/redis_demo/models/output.py
examples/redis_demo/models/secret.py
examples/redis_demo/models/setup.py
examples/redis_demo/triggers/__init__.py
examples/redis_demo/triggers/message_trigger.py
examples/services/filesystem_module.py
examples/services/storage_module.py
src/digitalkin/__init__.py
src/digitalkin/__version__.py
src/digitalkin/exceptions.py
src/digitalkin/logger.py
src/digitalkin/py.typed
src/digitalkin.egg-info/PKG-INFO
src/digitalkin.egg-info/SOURCES.txt
src/digitalkin.egg-info/dependency_links.txt
src/digitalkin.egg-info/requires.txt
src/digitalkin.egg-info/top_level.txt
src/digitalkin/community/__init__.py
src/digitalkin/community/agno/__init__.py
src/digitalkin/community/agno/agno_adapter.py
src/digitalkin/community/agno/agui_tools.py
src/digitalkin/community/agno/hitl.py
src/digitalkin/community/agno/models.py
src/digitalkin/core/__init__.py
src/digitalkin/core/exceptions.py
src/digitalkin/core/common/__init__.py
src/digitalkin/core/common/factories.py
src/digitalkin/core/job_manager/__init__.py
src/digitalkin/core/job_manager/base_job_manager.py
src/digitalkin/core/job_manager/single_job_manager.py
src/digitalkin/core/profiling/__init__.py
src/digitalkin/core/profiling/step_timer.py
src/digitalkin/core/profiling/task_profiler.py
src/digitalkin/core/resilience/__init__.py
src/digitalkin/core/resilience/bulkhead.py
src/digitalkin/core/resilience/task_supervisor.py
src/digitalkin/core/task_manager/__init__.py
src/digitalkin/core/task_manager/base_task_manager.py
src/digitalkin/core/task_manager/local_task_manager.py
src/digitalkin/core/task_manager/module_runner.py
src/digitalkin/core/task_manager/remote_task_manager.py
src/digitalkin/core/task_manager/task_executor.py
src/digitalkin/core/task_manager/task_session.py
src/digitalkin/core/task_manager/redis/__init__.py
src/digitalkin/core/task_manager/redis/instrumented.py
src/digitalkin/core/task_manager/redis/proto_streams.py
src/digitalkin/core/task_manager/redis/redis_checkpoint.py
src/digitalkin/core/task_manager/redis/redis_client.py
src/digitalkin/core/task_manager/redis/redis_idempotency.py
src/digitalkin/core/task_manager/redis/redis_signal.py
src/digitalkin/core/task_manager/redis/redis_state.py
src/digitalkin/core/task_manager/redis/redis_streams.py
src/digitalkin/core/task_manager/redis/shadow.py
src/digitalkin/grpc_servers/__init__.py
src/digitalkin/grpc_servers/_base_server.py
src/digitalkin/grpc_servers/exceptions.py
src/digitalkin/grpc_servers/gateway_servicer.py
src/digitalkin/grpc_servers/m2m_call_registry.py
src/digitalkin/grpc_servers/module_server.py
src/digitalkin/grpc_servers/module_servicer.py
src/digitalkin/grpc_servers/stream_registry.py
src/digitalkin/grpc_servers/stream_session.py
src/digitalkin/grpc_servers/interceptors/__init__.py
src/digitalkin/grpc_servers/interceptors/circuit_breaker_interceptor.py
src/digitalkin/grpc_servers/utils/__init__.py
src/digitalkin/grpc_servers/utils/circuit_breaker.py
src/digitalkin/grpc_servers/utils/grpc_client_wrapper.py
src/digitalkin/grpc_servers/utils/grpc_error_handler.py
src/digitalkin/grpc_servers/utils/utility_schema_extender.py
src/digitalkin/grpc_servers/utils/validators.py
src/digitalkin/mixins/__init__.py
src/digitalkin/mixins/agui_mixin.py
src/digitalkin/mixins/base_mixin.py
src/digitalkin/mixins/cost_mixin.py
src/digitalkin/mixins/file_history_mixin.py
src/digitalkin/mixins/filesystem_mixin.py
src/digitalkin/mixins/logger_mixin.py
src/digitalkin/mixins/storage_mixin.py
src/digitalkin/models/__init__.py
src/digitalkin/models/core/__init__.py
src/digitalkin/models/core/job_manager_models.py
src/digitalkin/models/core/redis.py
src/digitalkin/models/core/task_monitor.py
src/digitalkin/models/events/__init__.py
src/digitalkin/models/events/agent_events.py
src/digitalkin/models/grpc_servers/__init__.py
src/digitalkin/models/grpc_servers/circuit_breaker.py
src/digitalkin/models/grpc_servers/m2m.py
src/digitalkin/models/grpc_servers/models.py
src/digitalkin/models/grpc_servers/stream_error_codes.py
src/digitalkin/models/grpc_servers/types.py
src/digitalkin/models/module/__init__.py
src/digitalkin/models/module/ag_ui.py
src/digitalkin/models/module/base_types.py
src/digitalkin/models/module/module.py
src/digitalkin/models/module/module_context.py
src/digitalkin/models/module/module_types.py
src/digitalkin/models/module/request_metadata.py
src/digitalkin/models/module/select_schema.py
src/digitalkin/models/module/setup_types.py
src/digitalkin/models/module/tool_cache.py
src/digitalkin/models/module/tool_reference.py
src/digitalkin/models/module/utility.py
src/digitalkin/models/services/__init__.py
src/digitalkin/models/services/cost.py
src/digitalkin/models/services/registry.py
src/digitalkin/models/services/services.py
src/digitalkin/models/services/storage.py
src/digitalkin/models/settings/__init__.py
src/digitalkin/models/settings/consumer.py
src/digitalkin/models/settings/gateway.py
src/digitalkin/models/settings/grpc_client.py
src/digitalkin/models/settings/log.py
src/digitalkin/models/settings/module.py
src/digitalkin/models/settings/profiling.py
src/digitalkin/models/settings/queue.py
src/digitalkin/models/settings/redis.py
src/digitalkin/models/settings/resilience.py
src/digitalkin/models/settings/task_manager.py
src/digitalkin/models/settings/server/__init__.py
src/digitalkin/models/settings/server/channel.py
src/digitalkin/models/settings/server/grpc.py
src/digitalkin/models/settings/server/server.py
src/digitalkin/models/settings/server/servicer.py
src/digitalkin/models/settings/utils/__init__.py
src/digitalkin/models/settings/utils/channel.py
src/digitalkin/models/utils/__init__.py
src/digitalkin/models/utils/dynamic_schema.py
src/digitalkin/modules/__init__.py
src/digitalkin/modules/_base_module.py
src/digitalkin/modules/archetype_module.py
src/digitalkin/modules/tool_module.py
src/digitalkin/modules/trigger_handler.py
src/digitalkin/modules/triggers/__init__.py
src/digitalkin/modules/triggers/healthcheck_ping_trigger.py
src/digitalkin/modules/triggers/healthcheck_services_trigger.py
src/digitalkin/modules/triggers/healthcheck_status_trigger.py
src/digitalkin/services/__init__.py
src/digitalkin/services/base_strategy.py
src/digitalkin/services/services_config.py
src/digitalkin/services/services_models.py
src/digitalkin/services/communication/__init__.py
src/digitalkin/services/communication/communication_strategy.py
src/digitalkin/services/communication/default_communication.py
src/digitalkin/services/communication/exceptions.py
src/digitalkin/services/communication/grpc_communication.py
src/digitalkin/services/cost/__init__.py
src/digitalkin/services/cost/cost_strategy.py
src/digitalkin/services/cost/default_cost.py
src/digitalkin/services/cost/exceptions.py
src/digitalkin/services/cost/grpc_cost.py
src/digitalkin/services/filesystem/__init__.py
src/digitalkin/services/filesystem/default_filesystem.py
src/digitalkin/services/filesystem/exceptions.py
src/digitalkin/services/filesystem/filesystem_strategy.py
src/digitalkin/services/filesystem/grpc_filesystem.py
src/digitalkin/services/identity/__init__.py
src/digitalkin/services/identity/default_identity.py
src/digitalkin/services/identity/identity_strategy.py
src/digitalkin/services/registry/__init__.py
src/digitalkin/services/registry/default_registry.py
src/digitalkin/services/registry/exceptions.py
src/digitalkin/services/registry/grpc_registry.py
src/digitalkin/services/registry/registry_models.py
src/digitalkin/services/registry/registry_strategy.py
src/digitalkin/services/setup/__init__.py
src/digitalkin/services/setup/default_setup.py
src/digitalkin/services/setup/exceptions.py
src/digitalkin/services/setup/grpc_setup.py
src/digitalkin/services/setup/setup_strategy.py
src/digitalkin/services/storage/__init__.py
src/digitalkin/services/storage/default_storage.py
src/digitalkin/services/storage/exceptions.py
src/digitalkin/services/storage/grpc_storage.py
src/digitalkin/services/storage/storage_strategy.py
src/digitalkin/services/task_manager/__init__.py
src/digitalkin/services/task_manager/default_task_manager.py
src/digitalkin/services/task_manager/exceptions.py
src/digitalkin/services/task_manager/redis_task_manager.py
src/digitalkin/services/task_manager/task_manager_strategy.py
src/digitalkin/services/user_profile/__init__.py
src/digitalkin/services/user_profile/default_user_profile.py
src/digitalkin/services/user_profile/exceptions.py
src/digitalkin/services/user_profile/grpc_user_profile.py
src/digitalkin/services/user_profile/user_profile_strategy.py
src/digitalkin/utils/__init__.py
src/digitalkin/utils/arg_parser.py
src/digitalkin/utils/conditional_schema.py
src/digitalkin/utils/development_mode_action.py
src/digitalkin/utils/dynamic_schema.py
src/digitalkin/utils/exceptions.py
src/digitalkin/utils/llm_ready_schema.py
src/digitalkin/utils/package_discover.py
src/digitalkin/utils/proto_utils.py
src/digitalkin/utils/schema_splitter.py