From d0633180ae384a90747b02cd8aa36f0b344868e4 Mon Sep 17 00:00:00 2001 From: MRiganSUSX Date: Tue, 11 Nov 2025 17:07:06 +0100 Subject: [PATCH 1/2] adding data mount location --- schema/druncschema/process_manager.proto | 1 + 1 file changed, 1 insertion(+) diff --git a/schema/druncschema/process_manager.proto b/schema/druncschema/process_manager.proto index 0b0e382..f826803 100644 --- a/schema/druncschema/process_manager.proto +++ b/schema/druncschema/process_manager.proto @@ -20,6 +20,7 @@ service ProcessManager { message ProcessRestriction { repeated string allowed_hosts = 1; repeated string allowed_host_types = 2; + optional string data_mount = 3; } message CommandNotificationMessage { From 3da9e1e10cf399491be4f9ee763a6dce47b6e639 Mon Sep 17 00:00:00 2001 From: Pawel Plesniak Date: Wed, 12 Nov 2025 17:42:44 -0600 Subject: [PATCH 2/2] Michal you forgot to include the compiled script --- src/druncschema/authoriser_pb2.py | 6 +- src/druncschema/authoriser_pb2_grpc.py | 2 +- src/druncschema/broadcast_pb2.py | 6 +- src/druncschema/broadcast_pb2_grpc.py | 2 +- src/druncschema/controller_pb2.py | 6 +- src/druncschema/controller_pb2_grpc.py | 2 +- src/druncschema/description_pb2.py | 6 +- src/druncschema/description_pb2_grpc.py | 2 +- src/druncschema/generic_pb2.py | 6 +- src/druncschema/generic_pb2_grpc.py | 2 +- src/druncschema/opmon/FSM_pb2.py | 6 +- src/druncschema/opmon/generic_pb2.py | 6 +- src/druncschema/opmon/process_manager_pb2.py | 6 +- src/druncschema/process_manager_pb2.py | 82 ++++++++++---------- src/druncschema/process_manager_pb2.pyi | 7 +- src/druncschema/process_manager_pb2_grpc.py | 2 +- src/druncschema/request_response_pb2.py | 6 +- src/druncschema/request_response_pb2_grpc.py | 2 +- src/druncschema/session_manager_pb2.py | 6 +- src/druncschema/session_manager_pb2_grpc.py | 2 +- src/druncschema/token_pb2.py | 6 +- src/druncschema/token_pb2_grpc.py | 2 +- 22 files changed, 89 insertions(+), 84 deletions(-) diff --git a/src/druncschema/authoriser_pb2.py b/src/druncschema/authoriser_pb2.py index 36fa8d1..9966ae6 100644 --- a/src/druncschema/authoriser_pb2.py +++ b/src/druncschema/authoriser_pb2.py @@ -2,7 +2,7 @@ # Generated by the protocol buffer compiler. DO NOT EDIT! # NO CHECKED-IN PROTOBUF GENCODE # source: druncschema/authoriser.proto -# Protobuf Python Version: 5.28.1 +# Protobuf Python Version: 6.31.1 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool @@ -11,8 +11,8 @@ from google.protobuf.internal import builder as _builder _runtime_version.ValidateProtobufRuntimeVersion( _runtime_version.Domain.PUBLIC, - 5, - 28, + 6, + 31, 1, '', 'druncschema/authoriser.proto' diff --git a/src/druncschema/authoriser_pb2_grpc.py b/src/druncschema/authoriser_pb2_grpc.py index fd6f432..2ec5245 100644 --- a/src/druncschema/authoriser_pb2_grpc.py +++ b/src/druncschema/authoriser_pb2_grpc.py @@ -4,7 +4,7 @@ import warnings -GRPC_GENERATED_VERSION = '1.68.0' +GRPC_GENERATED_VERSION = '1.75.0' GRPC_VERSION = grpc.__version__ _version_not_supported = False diff --git a/src/druncschema/broadcast_pb2.py b/src/druncschema/broadcast_pb2.py index 5e2bd0e..6357c5b 100644 --- a/src/druncschema/broadcast_pb2.py +++ b/src/druncschema/broadcast_pb2.py @@ -2,7 +2,7 @@ # Generated by the protocol buffer compiler. DO NOT EDIT! # NO CHECKED-IN PROTOBUF GENCODE # source: druncschema/broadcast.proto -# Protobuf Python Version: 5.28.1 +# Protobuf Python Version: 6.31.1 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool @@ -11,8 +11,8 @@ from google.protobuf.internal import builder as _builder _runtime_version.ValidateProtobufRuntimeVersion( _runtime_version.Domain.PUBLIC, - 5, - 28, + 6, + 31, 1, '', 'druncschema/broadcast.proto' diff --git a/src/druncschema/broadcast_pb2_grpc.py b/src/druncschema/broadcast_pb2_grpc.py index 8e0dfc0..f542f69 100644 --- a/src/druncschema/broadcast_pb2_grpc.py +++ b/src/druncschema/broadcast_pb2_grpc.py @@ -7,7 +7,7 @@ from druncschema import generic_pb2 as druncschema_dot_generic__pb2 from druncschema import request_response_pb2 as druncschema_dot_request__response__pb2 -GRPC_GENERATED_VERSION = '1.68.0' +GRPC_GENERATED_VERSION = '1.75.0' GRPC_VERSION = grpc.__version__ _version_not_supported = False diff --git a/src/druncschema/controller_pb2.py b/src/druncschema/controller_pb2.py index f75c865..5395539 100644 --- a/src/druncschema/controller_pb2.py +++ b/src/druncschema/controller_pb2.py @@ -2,7 +2,7 @@ # Generated by the protocol buffer compiler. DO NOT EDIT! # NO CHECKED-IN PROTOBUF GENCODE # source: druncschema/controller.proto -# Protobuf Python Version: 5.28.1 +# Protobuf Python Version: 6.31.1 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool @@ -11,8 +11,8 @@ from google.protobuf.internal import builder as _builder _runtime_version.ValidateProtobufRuntimeVersion( _runtime_version.Domain.PUBLIC, - 5, - 28, + 6, + 31, 1, '', 'druncschema/controller.proto' diff --git a/src/druncschema/controller_pb2_grpc.py b/src/druncschema/controller_pb2_grpc.py index 45c206a..dbd0f14 100644 --- a/src/druncschema/controller_pb2_grpc.py +++ b/src/druncschema/controller_pb2_grpc.py @@ -6,7 +6,7 @@ from druncschema import controller_pb2 as druncschema_dot_controller__pb2 from druncschema import request_response_pb2 as druncschema_dot_request__response__pb2 -GRPC_GENERATED_VERSION = '1.68.0' +GRPC_GENERATED_VERSION = '1.75.0' GRPC_VERSION = grpc.__version__ _version_not_supported = False diff --git a/src/druncschema/description_pb2.py b/src/druncschema/description_pb2.py index d7a4c12..bad9faa 100644 --- a/src/druncschema/description_pb2.py +++ b/src/druncschema/description_pb2.py @@ -2,7 +2,7 @@ # Generated by the protocol buffer compiler. DO NOT EDIT! # NO CHECKED-IN PROTOBUF GENCODE # source: druncschema/description.proto -# Protobuf Python Version: 5.28.1 +# Protobuf Python Version: 6.31.1 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool @@ -11,8 +11,8 @@ from google.protobuf.internal import builder as _builder _runtime_version.ValidateProtobufRuntimeVersion( _runtime_version.Domain.PUBLIC, - 5, - 28, + 6, + 31, 1, '', 'druncschema/description.proto' diff --git a/src/druncschema/description_pb2_grpc.py b/src/druncschema/description_pb2_grpc.py index b48a865..848ce53 100644 --- a/src/druncschema/description_pb2_grpc.py +++ b/src/druncschema/description_pb2_grpc.py @@ -4,7 +4,7 @@ import warnings -GRPC_GENERATED_VERSION = '1.68.0' +GRPC_GENERATED_VERSION = '1.75.0' GRPC_VERSION = grpc.__version__ _version_not_supported = False diff --git a/src/druncschema/generic_pb2.py b/src/druncschema/generic_pb2.py index 2ef5169..c08d708 100644 --- a/src/druncschema/generic_pb2.py +++ b/src/druncschema/generic_pb2.py @@ -2,7 +2,7 @@ # Generated by the protocol buffer compiler. DO NOT EDIT! # NO CHECKED-IN PROTOBUF GENCODE # source: druncschema/generic.proto -# Protobuf Python Version: 5.28.1 +# Protobuf Python Version: 6.31.1 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool @@ -11,8 +11,8 @@ from google.protobuf.internal import builder as _builder _runtime_version.ValidateProtobufRuntimeVersion( _runtime_version.Domain.PUBLIC, - 5, - 28, + 6, + 31, 1, '', 'druncschema/generic.proto' diff --git a/src/druncschema/generic_pb2_grpc.py b/src/druncschema/generic_pb2_grpc.py index 3bdefaa..32e5ddd 100644 --- a/src/druncschema/generic_pb2_grpc.py +++ b/src/druncschema/generic_pb2_grpc.py @@ -4,7 +4,7 @@ import warnings -GRPC_GENERATED_VERSION = '1.68.0' +GRPC_GENERATED_VERSION = '1.75.0' GRPC_VERSION = grpc.__version__ _version_not_supported = False diff --git a/src/druncschema/opmon/FSM_pb2.py b/src/druncschema/opmon/FSM_pb2.py index 494385c..dca04b8 100644 --- a/src/druncschema/opmon/FSM_pb2.py +++ b/src/druncschema/opmon/FSM_pb2.py @@ -2,7 +2,7 @@ # Generated by the protocol buffer compiler. DO NOT EDIT! # NO CHECKED-IN PROTOBUF GENCODE # source: druncschema/opmon/FSM.proto -# Protobuf Python Version: 5.28.1 +# Protobuf Python Version: 6.31.1 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool @@ -11,8 +11,8 @@ from google.protobuf.internal import builder as _builder _runtime_version.ValidateProtobufRuntimeVersion( _runtime_version.Domain.PUBLIC, - 5, - 28, + 6, + 31, 1, '', 'druncschema/opmon/FSM.proto' diff --git a/src/druncschema/opmon/generic_pb2.py b/src/druncschema/opmon/generic_pb2.py index 242c0d6..f8f2dce 100644 --- a/src/druncschema/opmon/generic_pb2.py +++ b/src/druncschema/opmon/generic_pb2.py @@ -2,7 +2,7 @@ # Generated by the protocol buffer compiler. DO NOT EDIT! # NO CHECKED-IN PROTOBUF GENCODE # source: druncschema/opmon/generic.proto -# Protobuf Python Version: 5.28.1 +# Protobuf Python Version: 6.31.1 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool @@ -11,8 +11,8 @@ from google.protobuf.internal import builder as _builder _runtime_version.ValidateProtobufRuntimeVersion( _runtime_version.Domain.PUBLIC, - 5, - 28, + 6, + 31, 1, '', 'druncschema/opmon/generic.proto' diff --git a/src/druncschema/opmon/process_manager_pb2.py b/src/druncschema/opmon/process_manager_pb2.py index 0fe0257..a4cb2f3 100644 --- a/src/druncschema/opmon/process_manager_pb2.py +++ b/src/druncschema/opmon/process_manager_pb2.py @@ -2,7 +2,7 @@ # Generated by the protocol buffer compiler. DO NOT EDIT! # NO CHECKED-IN PROTOBUF GENCODE # source: druncschema/opmon/process_manager.proto -# Protobuf Python Version: 5.28.1 +# Protobuf Python Version: 6.31.1 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool @@ -11,8 +11,8 @@ from google.protobuf.internal import builder as _builder _runtime_version.ValidateProtobufRuntimeVersion( _runtime_version.Domain.PUBLIC, - 5, - 28, + 6, + 31, 1, '', 'druncschema/opmon/process_manager.proto' diff --git a/src/druncschema/process_manager_pb2.py b/src/druncschema/process_manager_pb2.py index 57b14c7..7bd5de1 100644 --- a/src/druncschema/process_manager_pb2.py +++ b/src/druncschema/process_manager_pb2.py @@ -2,7 +2,7 @@ # Generated by the protocol buffer compiler. DO NOT EDIT! # NO CHECKED-IN PROTOBUF GENCODE # source: druncschema/process_manager.proto -# Protobuf Python Version: 5.28.1 +# Protobuf Python Version: 6.31.1 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool @@ -11,8 +11,8 @@ from google.protobuf.internal import builder as _builder _runtime_version.ValidateProtobufRuntimeVersion( _runtime_version.Domain.PUBLIC, - 5, - 28, + 6, + 31, 1, '', 'druncschema/process_manager.proto' @@ -27,7 +27,7 @@ from druncschema import token_pb2 as druncschema_dot_token__pb2 -DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n!druncschema/process_manager.proto\x12#dunedaq.druncschema.process_manager\x1a\"druncschema/request_response.proto\x1a\x1d\x64runcschema/description.proto\x1a\x17\x64runcschema/token.proto\"G\n\x12ProcessRestriction\x12\x15\n\rallowed_hosts\x18\x01 \x03(\t\x12\x1a\n\x12\x61llowed_host_types\x18\x02 \x03(\t\";\n\x1a\x43ommandNotificationMessage\x12\x0c\n\x04user\x18\x01 \x01(\t\x12\x0f\n\x07\x63ommand\x18\x02 \x01(\t\"-\n\x1aGenericNotificationMessage\x12\x0f\n\x07message\x18\x01 \x01(\t\"\xc9\x01\n\x15\x45xceptionNotification\x12\x12\n\nerror_text\x18\x01 \x01(\t\x12Y\n\x0bstack_trace\x18\x02 \x03(\x0b\x32\x44.dunedaq.druncschema.process_manager.ExceptionNotification.StackLine\x1a\x41\n\tStackLine\x12\x11\n\tline_text\x18\x01 \x01(\t\x12\x13\n\x0bline_number\x18\x02 \x01(\t\x12\x0c\n\x04\x66ile\x18\x03 \x01(\t\"\x8a\x01\n\nLogRequest\x12)\n\x05token\x18\x01 \x01(\x0b\x32\x1a.dunedaq.druncschema.Token\x12@\n\x05query\x18\x02 \x01(\x0b\x32\x31.dunedaq.druncschema.process_manager.ProcessQuery\x12\x0f\n\x07how_far\x18\x03 \x01(\x05\"\xc3\x01\n\x08LogLines\x12\x0c\n\x04name\x18\x01 \x01(\t\x12)\n\x05token\x18\x02 \x01(\x0b\x32\x1a.dunedaq.druncschema.Token\x12>\n\x04uuid\x18\x03 \x01(\x0b\x32\x30.dunedaq.druncschema.process_manager.ProcessUUID\x12\r\n\x05lines\x18\x04 \x03(\t\x12/\n\x04\x66lag\x18\x05 \x01(\x0e\x32!.dunedaq.druncschema.ResponseFlag\"\x1b\n\x0bProcessUUID\x12\x0c\n\x04uuid\x18\x01 \x01(\t\"\xc3\x01\n\x0fProcessMetadata\x12>\n\x04uuid\x18\x01 \x01(\x0b\x32\x30.dunedaq.druncschema.process_manager.ProcessUUID\x12\x0c\n\x04user\x18\x02 \x01(\t\x12\x14\n\x07session\x18\x03 \x01(\tH\x00\x88\x01\x01\x12\x0c\n\x04name\x18\x04 \x01(\t\x12\x10\n\x08hostname\x18\x05 \x01(\t\x12\x14\n\x07tree_id\x18\x06 \x01(\tH\x01\x88\x01\x01\x42\n\n\x08_sessionB\n\n\x08_tree_id\"\xa8\x01\n\x0cProcessQuery\x12)\n\x05token\x18\x01 \x01(\x0b\x32\x1a.dunedaq.druncschema.Token\x12?\n\x05uuids\x18\x02 \x03(\x0b\x32\x30.dunedaq.druncschema.process_manager.ProcessUUID\x12\r\n\x05names\x18\x03 \x03(\t\x12\x0c\n\x04user\x18\x04 \x01(\t\x12\x0f\n\x07session\x18\x05 \x01(\t\"\xc7\x03\n\x12ProcessDescription\x12\x46\n\x08metadata\x18\x01 \x01(\x0b\x32\x34.dunedaq.druncschema.process_manager.ProcessMetadata\x12M\n\x03\x65nv\x18\x02 \x03(\x0b\x32@.dunedaq.druncschema.process_manager.ProcessDescription.EnvEntry\x12\x65\n\x18\x65xecutable_and_arguments\x18\x03 \x03(\x0b\x32\x43.dunedaq.druncschema.process_manager.ProcessDescription.ExecAndArgs\x12#\n\x1bprocess_execution_directory\x18\x04 \x01(\t\x12\x19\n\x11process_logs_path\x18\x05 \x01(\t\x1a\x1c\n\nStringList\x12\x0e\n\x06values\x18\x01 \x03(\t\x1a)\n\x0b\x45xecAndArgs\x12\x0c\n\x04\x65xec\x18\x01 \x01(\t\x12\x0c\n\x04\x61rgs\x18\x02 \x03(\t\x1a*\n\x08\x45nvEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"\x8d\x03\n\x0fProcessInstance\x12T\n\x13process_description\x18\x01 \x01(\x0b\x32\x37.dunedaq.druncschema.process_manager.ProcessDescription\x12T\n\x13process_restriction\x18\x02 \x01(\x0b\x32\x37.dunedaq.druncschema.process_manager.ProcessRestriction\x12T\n\x0bstatus_code\x18\x03 \x01(\x0e\x32?.dunedaq.druncschema.process_manager.ProcessInstance.StatusCode\x12\x13\n\x0breturn_code\x18\x04 \x01(\x05\x12>\n\x04uuid\x18\x05 \x01(\x0b\x32\x30.dunedaq.druncschema.process_manager.ProcessUUID\"#\n\nStatusCode\x12\x0b\n\x07RUNNING\x10\x00\x12\x08\n\x04\x44\x45\x41\x44\x10\x01\"\xc5\x01\n\x13ProcessInstanceList\x12\x0c\n\x04name\x18\x01 \x01(\t\x12)\n\x05token\x18\x02 \x01(\x0b\x32\x1a.dunedaq.druncschema.Token\x12\x44\n\x06values\x18\x03 \x03(\x0b\x32\x34.dunedaq.druncschema.process_manager.ProcessInstance\x12/\n\x04\x66lag\x18\x04 \x01(\x0e\x32!.dunedaq.druncschema.ResponseFlag\"\xe4\x01\n\x0b\x42ootRequest\x12)\n\x05token\x18\x01 \x01(\x0b\x32\x1a.dunedaq.druncschema.Token\x12T\n\x13process_description\x18\x02 \x01(\x0b\x32\x37.dunedaq.druncschema.process_manager.ProcessDescription\x12T\n\x13process_restriction\x18\x03 \x01(\x0b\x32\x37.dunedaq.druncschema.process_manager.ProcessRestriction2\x83\x07\n\x0eProcessManager\x12L\n\x08\x64\x65scribe\x12\x1c.dunedaq.druncschema.Request\x1a .dunedaq.druncschema.Description\"\x00\x12t\n\x04\x62oot\x12\x30.dunedaq.druncschema.process_manager.BootRequest\x1a\x38.dunedaq.druncschema.process_manager.ProcessInstanceList\"\x00\x12\x65\n\tterminate\x12\x1c.dunedaq.druncschema.Request\x1a\x38.dunedaq.druncschema.process_manager.ProcessInstanceList\"\x00\x12x\n\x07restart\x12\x31.dunedaq.druncschema.process_manager.ProcessQuery\x1a\x38.dunedaq.druncschema.process_manager.ProcessInstanceList\"\x00\x12u\n\x04kill\x12\x31.dunedaq.druncschema.process_manager.ProcessQuery\x1a\x38.dunedaq.druncschema.process_manager.ProcessInstanceList\"\x00\x12v\n\x05\x66lush\x12\x31.dunedaq.druncschema.process_manager.ProcessQuery\x1a\x38.dunedaq.druncschema.process_manager.ProcessInstanceList\"\x00\x12s\n\x02ps\x12\x31.dunedaq.druncschema.process_manager.ProcessQuery\x1a\x38.dunedaq.druncschema.process_manager.ProcessInstanceList\"\x00\x12h\n\x04logs\x12/.dunedaq.druncschema.process_manager.LogRequest\x1a-.dunedaq.druncschema.process_manager.LogLines\"\x00\x62\x06proto3') +DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n!druncschema/process_manager.proto\x12#dunedaq.druncschema.process_manager\x1a\"druncschema/request_response.proto\x1a\x1d\x64runcschema/description.proto\x1a\x17\x64runcschema/token.proto\"o\n\x12ProcessRestriction\x12\x15\n\rallowed_hosts\x18\x01 \x03(\t\x12\x1a\n\x12\x61llowed_host_types\x18\x02 \x03(\t\x12\x17\n\ndata_mount\x18\x03 \x01(\tH\x00\x88\x01\x01\x42\r\n\x0b_data_mount\";\n\x1a\x43ommandNotificationMessage\x12\x0c\n\x04user\x18\x01 \x01(\t\x12\x0f\n\x07\x63ommand\x18\x02 \x01(\t\"-\n\x1aGenericNotificationMessage\x12\x0f\n\x07message\x18\x01 \x01(\t\"\xc9\x01\n\x15\x45xceptionNotification\x12\x12\n\nerror_text\x18\x01 \x01(\t\x12Y\n\x0bstack_trace\x18\x02 \x03(\x0b\x32\x44.dunedaq.druncschema.process_manager.ExceptionNotification.StackLine\x1a\x41\n\tStackLine\x12\x11\n\tline_text\x18\x01 \x01(\t\x12\x13\n\x0bline_number\x18\x02 \x01(\t\x12\x0c\n\x04\x66ile\x18\x03 \x01(\t\"\x8a\x01\n\nLogRequest\x12)\n\x05token\x18\x01 \x01(\x0b\x32\x1a.dunedaq.druncschema.Token\x12@\n\x05query\x18\x02 \x01(\x0b\x32\x31.dunedaq.druncschema.process_manager.ProcessQuery\x12\x0f\n\x07how_far\x18\x03 \x01(\x05\"\xc3\x01\n\x08LogLines\x12\x0c\n\x04name\x18\x01 \x01(\t\x12)\n\x05token\x18\x02 \x01(\x0b\x32\x1a.dunedaq.druncschema.Token\x12>\n\x04uuid\x18\x03 \x01(\x0b\x32\x30.dunedaq.druncschema.process_manager.ProcessUUID\x12\r\n\x05lines\x18\x04 \x03(\t\x12/\n\x04\x66lag\x18\x05 \x01(\x0e\x32!.dunedaq.druncschema.ResponseFlag\"\x1b\n\x0bProcessUUID\x12\x0c\n\x04uuid\x18\x01 \x01(\t\"\xc3\x01\n\x0fProcessMetadata\x12>\n\x04uuid\x18\x01 \x01(\x0b\x32\x30.dunedaq.druncschema.process_manager.ProcessUUID\x12\x0c\n\x04user\x18\x02 \x01(\t\x12\x14\n\x07session\x18\x03 \x01(\tH\x00\x88\x01\x01\x12\x0c\n\x04name\x18\x04 \x01(\t\x12\x10\n\x08hostname\x18\x05 \x01(\t\x12\x14\n\x07tree_id\x18\x06 \x01(\tH\x01\x88\x01\x01\x42\n\n\x08_sessionB\n\n\x08_tree_id\"\xa8\x01\n\x0cProcessQuery\x12)\n\x05token\x18\x01 \x01(\x0b\x32\x1a.dunedaq.druncschema.Token\x12?\n\x05uuids\x18\x02 \x03(\x0b\x32\x30.dunedaq.druncschema.process_manager.ProcessUUID\x12\r\n\x05names\x18\x03 \x03(\t\x12\x0c\n\x04user\x18\x04 \x01(\t\x12\x0f\n\x07session\x18\x05 \x01(\t\"\xc7\x03\n\x12ProcessDescription\x12\x46\n\x08metadata\x18\x01 \x01(\x0b\x32\x34.dunedaq.druncschema.process_manager.ProcessMetadata\x12M\n\x03\x65nv\x18\x02 \x03(\x0b\x32@.dunedaq.druncschema.process_manager.ProcessDescription.EnvEntry\x12\x65\n\x18\x65xecutable_and_arguments\x18\x03 \x03(\x0b\x32\x43.dunedaq.druncschema.process_manager.ProcessDescription.ExecAndArgs\x12#\n\x1bprocess_execution_directory\x18\x04 \x01(\t\x12\x19\n\x11process_logs_path\x18\x05 \x01(\t\x1a\x1c\n\nStringList\x12\x0e\n\x06values\x18\x01 \x03(\t\x1a)\n\x0b\x45xecAndArgs\x12\x0c\n\x04\x65xec\x18\x01 \x01(\t\x12\x0c\n\x04\x61rgs\x18\x02 \x03(\t\x1a*\n\x08\x45nvEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"\x8d\x03\n\x0fProcessInstance\x12T\n\x13process_description\x18\x01 \x01(\x0b\x32\x37.dunedaq.druncschema.process_manager.ProcessDescription\x12T\n\x13process_restriction\x18\x02 \x01(\x0b\x32\x37.dunedaq.druncschema.process_manager.ProcessRestriction\x12T\n\x0bstatus_code\x18\x03 \x01(\x0e\x32?.dunedaq.druncschema.process_manager.ProcessInstance.StatusCode\x12\x13\n\x0breturn_code\x18\x04 \x01(\x05\x12>\n\x04uuid\x18\x05 \x01(\x0b\x32\x30.dunedaq.druncschema.process_manager.ProcessUUID\"#\n\nStatusCode\x12\x0b\n\x07RUNNING\x10\x00\x12\x08\n\x04\x44\x45\x41\x44\x10\x01\"\xc5\x01\n\x13ProcessInstanceList\x12\x0c\n\x04name\x18\x01 \x01(\t\x12)\n\x05token\x18\x02 \x01(\x0b\x32\x1a.dunedaq.druncschema.Token\x12\x44\n\x06values\x18\x03 \x03(\x0b\x32\x34.dunedaq.druncschema.process_manager.ProcessInstance\x12/\n\x04\x66lag\x18\x04 \x01(\x0e\x32!.dunedaq.druncschema.ResponseFlag\"\xe4\x01\n\x0b\x42ootRequest\x12)\n\x05token\x18\x01 \x01(\x0b\x32\x1a.dunedaq.druncschema.Token\x12T\n\x13process_description\x18\x02 \x01(\x0b\x32\x37.dunedaq.druncschema.process_manager.ProcessDescription\x12T\n\x13process_restriction\x18\x03 \x01(\x0b\x32\x37.dunedaq.druncschema.process_manager.ProcessRestriction2\x83\x07\n\x0eProcessManager\x12L\n\x08\x64\x65scribe\x12\x1c.dunedaq.druncschema.Request\x1a .dunedaq.druncschema.Description\"\x00\x12t\n\x04\x62oot\x12\x30.dunedaq.druncschema.process_manager.BootRequest\x1a\x38.dunedaq.druncschema.process_manager.ProcessInstanceList\"\x00\x12\x65\n\tterminate\x12\x1c.dunedaq.druncschema.Request\x1a\x38.dunedaq.druncschema.process_manager.ProcessInstanceList\"\x00\x12x\n\x07restart\x12\x31.dunedaq.druncschema.process_manager.ProcessQuery\x1a\x38.dunedaq.druncschema.process_manager.ProcessInstanceList\"\x00\x12u\n\x04kill\x12\x31.dunedaq.druncschema.process_manager.ProcessQuery\x1a\x38.dunedaq.druncschema.process_manager.ProcessInstanceList\"\x00\x12v\n\x05\x66lush\x12\x31.dunedaq.druncschema.process_manager.ProcessQuery\x1a\x38.dunedaq.druncschema.process_manager.ProcessInstanceList\"\x00\x12s\n\x02ps\x12\x31.dunedaq.druncschema.process_manager.ProcessQuery\x1a\x38.dunedaq.druncschema.process_manager.ProcessInstanceList\"\x00\x12h\n\x04logs\x12/.dunedaq.druncschema.process_manager.LogRequest\x1a-.dunedaq.druncschema.process_manager.LogLines\"\x00\x62\x06proto3') _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) @@ -37,41 +37,41 @@ _globals['_PROCESSDESCRIPTION_ENVENTRY']._loaded_options = None _globals['_PROCESSDESCRIPTION_ENVENTRY']._serialized_options = b'8\001' _globals['_PROCESSRESTRICTION']._serialized_start=166 - _globals['_PROCESSRESTRICTION']._serialized_end=237 - _globals['_COMMANDNOTIFICATIONMESSAGE']._serialized_start=239 - _globals['_COMMANDNOTIFICATIONMESSAGE']._serialized_end=298 - _globals['_GENERICNOTIFICATIONMESSAGE']._serialized_start=300 - _globals['_GENERICNOTIFICATIONMESSAGE']._serialized_end=345 - _globals['_EXCEPTIONNOTIFICATION']._serialized_start=348 - _globals['_EXCEPTIONNOTIFICATION']._serialized_end=549 - _globals['_EXCEPTIONNOTIFICATION_STACKLINE']._serialized_start=484 - _globals['_EXCEPTIONNOTIFICATION_STACKLINE']._serialized_end=549 - _globals['_LOGREQUEST']._serialized_start=552 - _globals['_LOGREQUEST']._serialized_end=690 - _globals['_LOGLINES']._serialized_start=693 - _globals['_LOGLINES']._serialized_end=888 - _globals['_PROCESSUUID']._serialized_start=890 - _globals['_PROCESSUUID']._serialized_end=917 - _globals['_PROCESSMETADATA']._serialized_start=920 - _globals['_PROCESSMETADATA']._serialized_end=1115 - _globals['_PROCESSQUERY']._serialized_start=1118 - _globals['_PROCESSQUERY']._serialized_end=1286 - _globals['_PROCESSDESCRIPTION']._serialized_start=1289 - _globals['_PROCESSDESCRIPTION']._serialized_end=1744 - _globals['_PROCESSDESCRIPTION_STRINGLIST']._serialized_start=1629 - _globals['_PROCESSDESCRIPTION_STRINGLIST']._serialized_end=1657 - _globals['_PROCESSDESCRIPTION_EXECANDARGS']._serialized_start=1659 - _globals['_PROCESSDESCRIPTION_EXECANDARGS']._serialized_end=1700 - _globals['_PROCESSDESCRIPTION_ENVENTRY']._serialized_start=1702 - _globals['_PROCESSDESCRIPTION_ENVENTRY']._serialized_end=1744 - _globals['_PROCESSINSTANCE']._serialized_start=1747 - _globals['_PROCESSINSTANCE']._serialized_end=2144 - _globals['_PROCESSINSTANCE_STATUSCODE']._serialized_start=2109 - _globals['_PROCESSINSTANCE_STATUSCODE']._serialized_end=2144 - _globals['_PROCESSINSTANCELIST']._serialized_start=2147 - _globals['_PROCESSINSTANCELIST']._serialized_end=2344 - _globals['_BOOTREQUEST']._serialized_start=2347 - _globals['_BOOTREQUEST']._serialized_end=2575 - _globals['_PROCESSMANAGER']._serialized_start=2578 - _globals['_PROCESSMANAGER']._serialized_end=3477 + _globals['_PROCESSRESTRICTION']._serialized_end=277 + _globals['_COMMANDNOTIFICATIONMESSAGE']._serialized_start=279 + _globals['_COMMANDNOTIFICATIONMESSAGE']._serialized_end=338 + _globals['_GENERICNOTIFICATIONMESSAGE']._serialized_start=340 + _globals['_GENERICNOTIFICATIONMESSAGE']._serialized_end=385 + _globals['_EXCEPTIONNOTIFICATION']._serialized_start=388 + _globals['_EXCEPTIONNOTIFICATION']._serialized_end=589 + _globals['_EXCEPTIONNOTIFICATION_STACKLINE']._serialized_start=524 + _globals['_EXCEPTIONNOTIFICATION_STACKLINE']._serialized_end=589 + _globals['_LOGREQUEST']._serialized_start=592 + _globals['_LOGREQUEST']._serialized_end=730 + _globals['_LOGLINES']._serialized_start=733 + _globals['_LOGLINES']._serialized_end=928 + _globals['_PROCESSUUID']._serialized_start=930 + _globals['_PROCESSUUID']._serialized_end=957 + _globals['_PROCESSMETADATA']._serialized_start=960 + _globals['_PROCESSMETADATA']._serialized_end=1155 + _globals['_PROCESSQUERY']._serialized_start=1158 + _globals['_PROCESSQUERY']._serialized_end=1326 + _globals['_PROCESSDESCRIPTION']._serialized_start=1329 + _globals['_PROCESSDESCRIPTION']._serialized_end=1784 + _globals['_PROCESSDESCRIPTION_STRINGLIST']._serialized_start=1669 + _globals['_PROCESSDESCRIPTION_STRINGLIST']._serialized_end=1697 + _globals['_PROCESSDESCRIPTION_EXECANDARGS']._serialized_start=1699 + _globals['_PROCESSDESCRIPTION_EXECANDARGS']._serialized_end=1740 + _globals['_PROCESSDESCRIPTION_ENVENTRY']._serialized_start=1742 + _globals['_PROCESSDESCRIPTION_ENVENTRY']._serialized_end=1784 + _globals['_PROCESSINSTANCE']._serialized_start=1787 + _globals['_PROCESSINSTANCE']._serialized_end=2184 + _globals['_PROCESSINSTANCE_STATUSCODE']._serialized_start=2149 + _globals['_PROCESSINSTANCE_STATUSCODE']._serialized_end=2184 + _globals['_PROCESSINSTANCELIST']._serialized_start=2187 + _globals['_PROCESSINSTANCELIST']._serialized_end=2384 + _globals['_BOOTREQUEST']._serialized_start=2387 + _globals['_BOOTREQUEST']._serialized_end=2615 + _globals['_PROCESSMANAGER']._serialized_start=2618 + _globals['_PROCESSMANAGER']._serialized_end=3517 # @@protoc_insertion_point(module_scope) diff --git a/src/druncschema/process_manager_pb2.pyi b/src/druncschema/process_manager_pb2.pyi index d2920ec..dea113d 100644 --- a/src/druncschema/process_manager_pb2.pyi +++ b/src/druncschema/process_manager_pb2.pyi @@ -27,6 +27,8 @@ class ProcessRestriction(google.protobuf.message.Message): ALLOWED_HOSTS_FIELD_NUMBER: builtins.int ALLOWED_HOST_TYPES_FIELD_NUMBER: builtins.int + DATA_MOUNT_FIELD_NUMBER: builtins.int + data_mount: builtins.str @property def allowed_hosts(self) -> google.protobuf.internal.containers.RepeatedScalarFieldContainer[builtins.str]: ... @property @@ -36,8 +38,11 @@ class ProcessRestriction(google.protobuf.message.Message): *, allowed_hosts: collections.abc.Iterable[builtins.str] | None = ..., allowed_host_types: collections.abc.Iterable[builtins.str] | None = ..., + data_mount: builtins.str | None = ..., ) -> None: ... - def ClearField(self, field_name: typing.Literal["allowed_host_types", b"allowed_host_types", "allowed_hosts", b"allowed_hosts"]) -> None: ... + def HasField(self, field_name: typing.Literal["_data_mount", b"_data_mount", "data_mount", b"data_mount"]) -> builtins.bool: ... + def ClearField(self, field_name: typing.Literal["_data_mount", b"_data_mount", "allowed_host_types", b"allowed_host_types", "allowed_hosts", b"allowed_hosts", "data_mount", b"data_mount"]) -> None: ... + def WhichOneof(self, oneof_group: typing.Literal["_data_mount", b"_data_mount"]) -> typing.Literal["data_mount"] | None: ... global___ProcessRestriction = ProcessRestriction diff --git a/src/druncschema/process_manager_pb2_grpc.py b/src/druncschema/process_manager_pb2_grpc.py index c408dfd..650a826 100644 --- a/src/druncschema/process_manager_pb2_grpc.py +++ b/src/druncschema/process_manager_pb2_grpc.py @@ -7,7 +7,7 @@ from druncschema import process_manager_pb2 as druncschema_dot_process__manager__pb2 from druncschema import request_response_pb2 as druncschema_dot_request__response__pb2 -GRPC_GENERATED_VERSION = '1.68.0' +GRPC_GENERATED_VERSION = '1.75.0' GRPC_VERSION = grpc.__version__ _version_not_supported = False diff --git a/src/druncschema/request_response_pb2.py b/src/druncschema/request_response_pb2.py index a3c05d8..b7052f4 100644 --- a/src/druncschema/request_response_pb2.py +++ b/src/druncschema/request_response_pb2.py @@ -2,7 +2,7 @@ # Generated by the protocol buffer compiler. DO NOT EDIT! # NO CHECKED-IN PROTOBUF GENCODE # source: druncschema/request_response.proto -# Protobuf Python Version: 5.28.1 +# Protobuf Python Version: 6.31.1 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool @@ -11,8 +11,8 @@ from google.protobuf.internal import builder as _builder _runtime_version.ValidateProtobufRuntimeVersion( _runtime_version.Domain.PUBLIC, - 5, - 28, + 6, + 31, 1, '', 'druncschema/request_response.proto' diff --git a/src/druncschema/request_response_pb2_grpc.py b/src/druncschema/request_response_pb2_grpc.py index 79081a6..38162d2 100644 --- a/src/druncschema/request_response_pb2_grpc.py +++ b/src/druncschema/request_response_pb2_grpc.py @@ -4,7 +4,7 @@ import warnings -GRPC_GENERATED_VERSION = '1.68.0' +GRPC_GENERATED_VERSION = '1.75.0' GRPC_VERSION = grpc.__version__ _version_not_supported = False diff --git a/src/druncschema/session_manager_pb2.py b/src/druncschema/session_manager_pb2.py index 06a7cb5..6bd90a4 100644 --- a/src/druncschema/session_manager_pb2.py +++ b/src/druncschema/session_manager_pb2.py @@ -2,7 +2,7 @@ # Generated by the protocol buffer compiler. DO NOT EDIT! # NO CHECKED-IN PROTOBUF GENCODE # source: druncschema/session_manager.proto -# Protobuf Python Version: 5.28.1 +# Protobuf Python Version: 6.31.1 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool @@ -11,8 +11,8 @@ from google.protobuf.internal import builder as _builder _runtime_version.ValidateProtobufRuntimeVersion( _runtime_version.Domain.PUBLIC, - 5, - 28, + 6, + 31, 1, '', 'druncschema/session_manager.proto' diff --git a/src/druncschema/session_manager_pb2_grpc.py b/src/druncschema/session_manager_pb2_grpc.py index a03893e..0313285 100644 --- a/src/druncschema/session_manager_pb2_grpc.py +++ b/src/druncschema/session_manager_pb2_grpc.py @@ -7,7 +7,7 @@ from druncschema import request_response_pb2 as druncschema_dot_request__response__pb2 from druncschema import session_manager_pb2 as druncschema_dot_session__manager__pb2 -GRPC_GENERATED_VERSION = '1.68.0' +GRPC_GENERATED_VERSION = '1.75.0' GRPC_VERSION = grpc.__version__ _version_not_supported = False diff --git a/src/druncschema/token_pb2.py b/src/druncschema/token_pb2.py index 691e305..c712e4a 100644 --- a/src/druncschema/token_pb2.py +++ b/src/druncschema/token_pb2.py @@ -2,7 +2,7 @@ # Generated by the protocol buffer compiler. DO NOT EDIT! # NO CHECKED-IN PROTOBUF GENCODE # source: druncschema/token.proto -# Protobuf Python Version: 5.28.1 +# Protobuf Python Version: 6.31.1 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool @@ -11,8 +11,8 @@ from google.protobuf.internal import builder as _builder _runtime_version.ValidateProtobufRuntimeVersion( _runtime_version.Domain.PUBLIC, - 5, - 28, + 6, + 31, 1, '', 'druncschema/token.proto' diff --git a/src/druncschema/token_pb2_grpc.py b/src/druncschema/token_pb2_grpc.py index 291a0c1..4ec988d 100644 --- a/src/druncschema/token_pb2_grpc.py +++ b/src/druncschema/token_pb2_grpc.py @@ -4,7 +4,7 @@ import warnings -GRPC_GENERATED_VERSION = '1.68.0' +GRPC_GENERATED_VERSION = '1.75.0' GRPC_VERSION = grpc.__version__ _version_not_supported = False