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/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/services/filesystem_module.py
examples/services/storage_module.py
src/digitalkin/__init__.py
src/digitalkin/__version__.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/core/__init__.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/job_manager/taskiq_broker.py
src/digitalkin/core/job_manager/taskiq_job_manager.py
src/digitalkin/core/profiling/__init__.py
src/digitalkin/core/profiling/asyncio_monitor.py
src/digitalkin/core/profiling/task_profiler.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/remote_task_manager.py
src/digitalkin/core/task_manager/task_executor.py
src/digitalkin/core/task_manager/task_session.py
src/digitalkin/grpc_servers/__init__.py
src/digitalkin/grpc_servers/_base_server.py
src/digitalkin/grpc_servers/module_server.py
src/digitalkin/grpc_servers/module_servicer.py
src/digitalkin/grpc_servers/utils/__init__.py
src/digitalkin/grpc_servers/utils/exceptions.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/mixins/__init__.py
src/digitalkin/mixins/agui_mixin.py
src/digitalkin/mixins/base_mixin.py
src/digitalkin/mixins/callback_mixin.py
src/digitalkin/mixins/chat_history_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/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/models.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/storage.py
src/digitalkin/models/settings/__init__.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/utils/__init__.py
src/digitalkin/models/settings/utils/channel.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/agent/__init__.py
src/digitalkin/services/agent/agent_strategy.py
src/digitalkin/services/agent/default_agent.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/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/grpc_cost.py
src/digitalkin/services/filesystem/__init__.py
src/digitalkin/services/filesystem/default_filesystem.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/grpc_setup.py
src/digitalkin/services/setup/setup_strategy.py
src/digitalkin/services/snapshot/__init__.py
src/digitalkin/services/snapshot/default_snapshot.py
src/digitalkin/services/snapshot/snapshot_strategy.py
src/digitalkin/services/storage/__init__.py
src/digitalkin/services/storage/default_storage.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/grpc_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/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/llm_ready_schema.py
src/digitalkin/utils/package_discover.py
src/digitalkin/utils/proto_utils.py
src/digitalkin/utils/schema_splitter.py