diff --git a/schema/druncschema/generic.proto b/schema/druncschema/generic.proto
index fe08b9e..f478e9b 100644
--- a/schema/druncschema/generic.proto
+++ b/schema/druncschema/generic.proto
@@ -2,6 +2,14 @@ syntax = "proto3";
 
 package dunedaq.druncschema;
 
+
+enum OutcomeFlag {
+  SUCCESS = 0;
+  FAIL = 1;
+  UNKNOWN = 2;
+}
+
+
 message Empty { }
 
 message PlainText {
@@ -30,4 +38,8 @@ message string_msg{
 }
 message bool_msg{
   bool value=1;
+}
+
+message OutcomeStatus{
+  OutcomeFlag flag=1;
 }
\ No newline at end of file
diff --git a/schema/druncschema/process_manager.proto b/schema/druncschema/process_manager.proto
index 821aefd..a51c6ac 100644
--- a/schema/druncschema/process_manager.proto
+++ b/schema/druncschema/process_manager.proto
@@ -5,8 +5,10 @@ package dunedaq.druncschema.process_manager;
 import "druncschema/request_response.proto";
 import "druncschema/description.proto";
 import "druncschema/token.proto";
+import "druncschema/generic.proto";
 
 service ProcessManager {
+  rpc send_msg  (Request) returns (OutcomeStatus) {}
   rpc describe  (Request) returns (Description) {}
   rpc boot      (BootRequest) returns (ProcessInstanceList) {}
   rpc terminate (Request) returns (ProcessInstanceList) {}
diff --git a/src/druncschema/authoriser_pb2.pyi b/src/druncschema/authoriser_pb2.pyi
index ca678d1..dfcef95 100644
--- a/src/druncschema/authoriser_pb2.pyi
+++ b/src/druncschema/authoriser_pb2.pyi
@@ -11,10 +11,10 @@ import builtins as _builtins
 import sys
 import typing as _typing
 
-if sys.version_info >= (3, 10):
-    from typing import TypeAlias as _TypeAlias
+if sys.version_info >= (3, 11):
+    from typing import TypeAlias as _TypeAlias, Never as _Never
 else:
-    from typing_extensions import TypeAlias as _TypeAlias
+    from typing_extensions import TypeAlias as _TypeAlias, Never as _Never
 
 DESCRIPTOR: _descriptor.FileDescriptor
 
@@ -84,5 +84,6 @@ class AuthoriserRequest(_message.Message):
     def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["action", b"action", "system", b"system", "token", b"token"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___AuthoriserRequest: _TypeAlias = AuthoriserRequest  # noqa: Y015
diff --git a/src/druncschema/broadcast_pb2.pyi b/src/druncschema/broadcast_pb2.pyi
index 17777c4..0a744e6 100644
--- a/src/druncschema/broadcast_pb2.pyi
+++ b/src/druncschema/broadcast_pb2.pyi
@@ -11,10 +11,10 @@ import builtins as _builtins
 import sys
 import typing as _typing
 
-if sys.version_info >= (3, 10):
-    from typing import TypeAlias as _TypeAlias
+if sys.version_info >= (3, 11):
+    from typing import TypeAlias as _TypeAlias, Never as _Never
 else:
-    from typing_extensions import TypeAlias as _TypeAlias
+    from typing_extensions import TypeAlias as _TypeAlias, Never as _Never
 
 DESCRIPTOR: _descriptor.FileDescriptor
 
@@ -79,8 +79,11 @@ class KafkaBroadcastHandlerConfiguration(_message.Message):
         kafka_address: _builtins.str = ...,
         topic: _builtins.str = ...,
     ) -> None: ...
+    _HasFieldArgType: _TypeAlias = _Never  # noqa: Y015
+    def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["kafka_address", b"kafka_address", "topic", b"topic"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___KafkaBroadcastHandlerConfiguration: _TypeAlias = KafkaBroadcastHandlerConfiguration  # noqa: Y015
 
@@ -98,8 +101,11 @@ class Emitter(_message.Message):
         process: _builtins.str = ...,
         session: _builtins.str = ...,
     ) -> None: ...
+    _HasFieldArgType: _TypeAlias = _Never  # noqa: Y015
+    def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["process", b"process", "session", b"session"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___Emitter: _TypeAlias = Emitter  # noqa: Y015
 
@@ -126,6 +132,7 @@ class BroadcastMessage(_message.Message):
     def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["data", b"data", "emitter", b"emitter", "type", b"type"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___BroadcastMessage: _TypeAlias = BroadcastMessage  # noqa: Y015
 
@@ -140,8 +147,11 @@ class BroadcastRequest(_message.Message):
         *,
         broadcast_receiver_address: _builtins.str = ...,
     ) -> None: ...
+    _HasFieldArgType: _TypeAlias = _Never  # noqa: Y015
+    def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["broadcast_receiver_address", b"broadcast_receiver_address"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___BroadcastRequest: _TypeAlias = BroadcastRequest  # noqa: Y015
 
@@ -156,7 +166,10 @@ class BroadcastResponse(_message.Message):
         *,
         success: _builtins.bool = ...,
     ) -> None: ...
+    _HasFieldArgType: _TypeAlias = _Never  # noqa: Y015
+    def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["success", b"success"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___BroadcastResponse: _TypeAlias = BroadcastResponse  # noqa: Y015
diff --git a/src/druncschema/controller_pb2.pyi b/src/druncschema/controller_pb2.pyi
index 9f91d33..d72d6c9 100644
--- a/src/druncschema/controller_pb2.pyi
+++ b/src/druncschema/controller_pb2.pyi
@@ -16,10 +16,10 @@ import builtins as _builtins
 import sys
 import typing as _typing
 
-if sys.version_info >= (3, 10):
-    from typing import TypeAlias as _TypeAlias
+if sys.version_info >= (3, 11):
+    from typing import TypeAlias as _TypeAlias, Never as _Never
 else:
-    from typing_extensions import TypeAlias as _TypeAlias
+    from typing_extensions import TypeAlias as _TypeAlias, Never as _Never
 
 DESCRIPTOR: _descriptor.FileDescriptor
 
@@ -110,6 +110,7 @@ class ExecuteExpertCommandRequest(_message.Message):
     def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["execute_along_path", b"execute_along_path", "execute_on_all_subsequent_children_in_path", b"execute_on_all_subsequent_children_in_path", "json_string", b"json_string", "target", b"target", "token", b"token"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___ExecuteExpertCommandRequest: _TypeAlias = ExecuteExpertCommandRequest  # noqa: Y015
 
@@ -145,6 +146,7 @@ class ExecuteExpertCommandResponse(_message.Message):
     def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["children", b"children", "data", b"data", "flag", b"flag", "fsm_flag", b"fsm_flag", "name", b"name", "token", b"token"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___ExecuteExpertCommandResponse: _TypeAlias = ExecuteExpertCommandResponse  # noqa: Y015
 
@@ -177,6 +179,7 @@ class ExecuteFSMCommandRequest(_message.Message):
     def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["command", b"command", "execute_along_path", b"execute_along_path", "execute_on_all_subsequent_children_in_path", b"execute_on_all_subsequent_children_in_path", "target", b"target", "token", b"token"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___ExecuteFSMCommandRequest: _TypeAlias = ExecuteFSMCommandRequest  # noqa: Y015
 
@@ -215,6 +218,7 @@ class ExecuteFSMCommandResponse(_message.Message):
     def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["children", b"children", "command_name", b"command_name", "data", b"data", "flag", b"flag", "fsm_flag", b"fsm_flag", "name", b"name", "token", b"token"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___ExecuteFSMCommandResponse: _TypeAlias = ExecuteFSMCommandResponse  # noqa: Y015
 
@@ -241,6 +245,7 @@ class FSMCommand(_message.Message):
         def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
         _ClearFieldArgType: _TypeAlias = _typing.Literal["key", b"key", "value", b"value"]  # noqa: Y015
         def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+        def WhichOneof(self, oneof_group: _Never) -> None: ...
 
     COMMAND_NAME_FIELD_NUMBER: _builtins.int
     ARGUMENTS_FIELD_NUMBER: _builtins.int
@@ -291,6 +296,7 @@ class IncludeRequest(_message.Message):
     def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["execute_along_path", b"execute_along_path", "execute_on_all_subsequent_children_in_path", b"execute_on_all_subsequent_children_in_path", "target", b"target", "token", b"token"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___IncludeRequest: _TypeAlias = IncludeRequest  # noqa: Y015
 
@@ -323,6 +329,7 @@ class IncludeResponse(_message.Message):
     def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["children", b"children", "flag", b"flag", "name", b"name", "text", b"text", "token", b"token"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___IncludeResponse: _TypeAlias = IncludeResponse  # noqa: Y015
 
@@ -351,6 +358,7 @@ class ExcludeRequest(_message.Message):
     def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["execute_along_path", b"execute_along_path", "execute_on_all_subsequent_children_in_path", b"execute_on_all_subsequent_children_in_path", "target", b"target", "token", b"token"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___ExcludeRequest: _TypeAlias = ExcludeRequest  # noqa: Y015
 
@@ -383,6 +391,7 @@ class ExcludeResponse(_message.Message):
     def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["children", b"children", "flag", b"flag", "name", b"name", "text", b"text", "token", b"token"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___ExcludeResponse: _TypeAlias = ExcludeResponse  # noqa: Y015
 
@@ -411,6 +420,7 @@ class TakeControlRequest(_message.Message):
     def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["execute_along_path", b"execute_along_path", "execute_on_all_subsequent_children_in_path", b"execute_on_all_subsequent_children_in_path", "target", b"target", "token", b"token"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___TakeControlRequest: _TypeAlias = TakeControlRequest  # noqa: Y015
 
@@ -443,6 +453,7 @@ class TakeControlResponse(_message.Message):
     def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["children", b"children", "flag", b"flag", "name", b"name", "text", b"text", "token", b"token"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___TakeControlResponse: _TypeAlias = TakeControlResponse  # noqa: Y015
 
@@ -471,6 +482,7 @@ class SurrenderControlRequest(_message.Message):
     def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["execute_along_path", b"execute_along_path", "execute_on_all_subsequent_children_in_path", b"execute_on_all_subsequent_children_in_path", "target", b"target", "token", b"token"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___SurrenderControlRequest: _TypeAlias = SurrenderControlRequest  # noqa: Y015
 
@@ -503,6 +515,7 @@ class SurrenderControlResponse(_message.Message):
     def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["children", b"children", "flag", b"flag", "name", b"name", "text", b"text", "token", b"token"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___SurrenderControlResponse: _TypeAlias = SurrenderControlResponse  # noqa: Y015
 
@@ -531,6 +544,7 @@ class WhoIsInChargeRequest(_message.Message):
     def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["execute_along_path", b"execute_along_path", "execute_on_all_subsequent_children_in_path", b"execute_on_all_subsequent_children_in_path", "target", b"target", "token", b"token"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___WhoIsInChargeRequest: _TypeAlias = WhoIsInChargeRequest  # noqa: Y015
 
@@ -563,6 +577,7 @@ class WhoIsInChargeResponse(_message.Message):
     def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["children", b"children", "flag", b"flag", "name", b"name", "text", b"text", "token", b"token"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___WhoIsInChargeResponse: _TypeAlias = WhoIsInChargeResponse  # noqa: Y015
 
@@ -591,6 +606,7 @@ class ToErrorRequest(_message.Message):
     def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["execute_along_path", b"execute_along_path", "execute_on_all_subsequent_children_in_path", b"execute_on_all_subsequent_children_in_path", "target", b"target", "token", b"token"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___ToErrorRequest: _TypeAlias = ToErrorRequest  # noqa: Y015
 
@@ -620,6 +636,7 @@ class ToErrorResponse(_message.Message):
     def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["children", b"children", "flag", b"flag", "name", b"name", "token", b"token"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___ToErrorResponse: _TypeAlias = ToErrorResponse  # noqa: Y015
 
@@ -648,6 +665,7 @@ class StatusRequest(_message.Message):
     def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["execute_along_path", b"execute_along_path", "execute_on_all_subsequent_children_in_path", b"execute_on_all_subsequent_children_in_path", "target", b"target", "token", b"token"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___StatusRequest: _TypeAlias = StatusRequest  # noqa: Y015
 
@@ -681,6 +699,7 @@ class StatusResponse(_message.Message):
     def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["children", b"children", "flag", b"flag", "name", b"name", "status", b"status", "token", b"token"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___StatusResponse: _TypeAlias = StatusResponse  # noqa: Y015
 
@@ -709,6 +728,7 @@ class RecomputeStatusRequest(_message.Message):
     def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["execute_along_path", b"execute_along_path", "execute_on_all_subsequent_children_in_path", b"execute_on_all_subsequent_children_in_path", "target", b"target", "token", b"token"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___RecomputeStatusRequest: _TypeAlias = RecomputeStatusRequest  # noqa: Y015
 
@@ -738,6 +758,7 @@ class RecomputeStatusResponse(_message.Message):
     def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["children", b"children", "flag", b"flag", "name", b"name", "token", b"token"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___RecomputeStatusResponse: _TypeAlias = RecomputeStatusResponse  # noqa: Y015
 
@@ -766,6 +787,7 @@ class DescribeRequest(_message.Message):
     def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["execute_along_path", b"execute_along_path", "execute_on_all_subsequent_children_in_path", b"execute_on_all_subsequent_children_in_path", "target", b"target", "token", b"token"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___DescribeRequest: _TypeAlias = DescribeRequest  # noqa: Y015
 
@@ -799,6 +821,7 @@ class DescribeResponse(_message.Message):
     def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["children", b"children", "description", b"description", "flag", b"flag", "name", b"name", "token", b"token"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___DescribeResponse: _TypeAlias = DescribeResponse  # noqa: Y015
 
@@ -830,6 +853,7 @@ class DescribeFSMRequest(_message.Message):
     def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["execute_along_path", b"execute_along_path", "execute_on_all_subsequent_children_in_path", b"execute_on_all_subsequent_children_in_path", "key", b"key", "target", b"target", "token", b"token"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___DescribeFSMRequest: _TypeAlias = DescribeFSMRequest  # noqa: Y015
 
@@ -863,6 +887,7 @@ class DescribeFSMResponse(_message.Message):
     def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["children", b"children", "description", b"description", "flag", b"flag", "name", b"name", "token", b"token"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___DescribeFSMResponse: _TypeAlias = DescribeFSMResponse  # noqa: Y015
 
@@ -959,8 +984,11 @@ class FSMCommandDescription(_message.Message):
         return_type: _builtins.str = ...,
         arguments: _abc.Iterable[Global___Argument] | None = ...,
     ) -> None: ...
+    _HasFieldArgType: _TypeAlias = _Never  # noqa: Y015
+    def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["arguments", b"arguments", "data_type", b"data_type", "help", b"help", "name", b"name", "return_type", b"return_type"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___FSMCommandDescription: _TypeAlias = FSMCommandDescription  # noqa: Y015
 
@@ -979,8 +1007,11 @@ class FSMSequence(_message.Message):
         id: _builtins.str = ...,
         command_ids: _abc.Iterable[_builtins.str] | None = ...,
     ) -> None: ...
+    _HasFieldArgType: _TypeAlias = _Never  # noqa: Y015
+    def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["command_ids", b"command_ids", "id", b"id"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___FSMSequence: _TypeAlias = FSMSequence  # noqa: Y015
 
@@ -1089,7 +1120,10 @@ class RunInfo(_message.Message):
         run_config_file: _builtins.str = ...,
         run_config_name: _builtins.str = ...,
     ) -> None: ...
+    _HasFieldArgType: _TypeAlias = _Never  # noqa: Y015
+    def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["disable_data_storage", b"disable_data_storage", "run_config_file", b"run_config_file", "run_config_name", b"run_config_name", "run_number", b"run_number", "run_time_at_start", b"run_time_at_start", "run_time_since_start", b"run_time_since_start", "run_type", b"run_type", "trigger_rate", b"trigger_rate"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___RunInfo: _TypeAlias = RunInfo  # noqa: Y015
diff --git a/src/druncschema/description_pb2.pyi b/src/druncschema/description_pb2.pyi
index 8485592..189a332 100644
--- a/src/druncschema/description_pb2.pyi
+++ b/src/druncschema/description_pb2.pyi
@@ -14,10 +14,10 @@ import builtins as _builtins
 import sys
 import typing as _typing
 
-if sys.version_info >= (3, 10):
-    from typing import TypeAlias as _TypeAlias
+if sys.version_info >= (3, 11):
+    from typing import TypeAlias as _TypeAlias, Never as _Never
 else:
-    from typing_extensions import TypeAlias as _TypeAlias
+    from typing_extensions import TypeAlias as _TypeAlias, Never as _Never
 
 DESCRIPTOR: _descriptor.FileDescriptor
 
@@ -42,8 +42,11 @@ class CommandDescription(_message.Message):
         help: _builtins.str = ...,
         return_type: _builtins.str = ...,
     ) -> None: ...
+    _HasFieldArgType: _TypeAlias = _Never  # noqa: Y015
+    def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["data_type", b"data_type", "help", b"help", "name", b"name", "return_type", b"return_type"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___CommandDescription: _TypeAlias = CommandDescription  # noqa: Y015
 
diff --git a/src/druncschema/generic_pb2.py b/src/druncschema/generic_pb2.py
index c08d708..07e91c7 100644
--- a/src/druncschema/generic_pb2.py
+++ b/src/druncschema/generic_pb2.py
@@ -24,7 +24,7 @@
 
 
 
-DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x19\x64runcschema/generic.proto\x12\x13\x64unedaq.druncschema\"\x07\n\x05\x45mpty\"\x19\n\tPlainText\x12\x0c\n\x04text\x18\x01 \x01(\t\"\x1f\n\x0fPlainTextVector\x12\x0c\n\x04text\x18\x01 \x03(\t\"\x1a\n\nStacktrace\x12\x0c\n\x04text\x18\x01 \x03(\t\"y\n\x0fStringStringMap\x12:\n\x03map\x18\x01 \x03(\x0b\x32-.dunedaq.druncschema.StringStringMap.MapEntry\x1a*\n\x08MapEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"\x18\n\x07int_msg\x12\r\n\x05value\x18\x01 \x01(\x03\"\x1a\n\tfloat_msg\x12\r\n\x05value\x18\x01 \x01(\x02\"\x1b\n\nstring_msg\x12\r\n\x05value\x18\x01 \x01(\t\"\x19\n\x08\x62ool_msg\x12\r\n\x05value\x18\x01 \x01(\x08\x62\x06proto3')
+DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x19\x64runcschema/generic.proto\x12\x13\x64unedaq.druncschema\"\x07\n\x05\x45mpty\"\x19\n\tPlainText\x12\x0c\n\x04text\x18\x01 \x01(\t\"\x1f\n\x0fPlainTextVector\x12\x0c\n\x04text\x18\x01 \x03(\t\"\x1a\n\nStacktrace\x12\x0c\n\x04text\x18\x01 \x03(\t\"y\n\x0fStringStringMap\x12:\n\x03map\x18\x01 \x03(\x0b\x32-.dunedaq.druncschema.StringStringMap.MapEntry\x1a*\n\x08MapEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"\x18\n\x07int_msg\x12\r\n\x05value\x18\x01 \x01(\x03\"\x1a\n\tfloat_msg\x12\r\n\x05value\x18\x01 \x01(\x02\"\x1b\n\nstring_msg\x12\r\n\x05value\x18\x01 \x01(\t\"\x19\n\x08\x62ool_msg\x12\r\n\x05value\x18\x01 \x01(\x08\"?\n\rOutcomeStatus\x12.\n\x04\x66lag\x18\x01 \x01(\x0e\x32 .dunedaq.druncschema.OutcomeFlag*1\n\x0bOutcomeFlag\x12\x0b\n\x07SUCCESS\x10\x00\x12\x08\n\x04\x46\x41IL\x10\x01\x12\x0b\n\x07UNKNOWN\x10\x02\x62\x06proto3')
 
 _globals = globals()
 _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals)
@@ -33,6 +33,8 @@
   DESCRIPTOR._loaded_options = None
   _globals['_STRINGSTRINGMAP_MAPENTRY']._loaded_options = None
   _globals['_STRINGSTRINGMAP_MAPENTRY']._serialized_options = b'8\001'
+  _globals['_OUTCOMEFLAG']._serialized_start=445
+  _globals['_OUTCOMEFLAG']._serialized_end=494
   _globals['_EMPTY']._serialized_start=50
   _globals['_EMPTY']._serialized_end=57
   _globals['_PLAINTEXT']._serialized_start=59
@@ -53,4 +55,6 @@
   _globals['_STRING_MSG']._serialized_end=351
   _globals['_BOOL_MSG']._serialized_start=353
   _globals['_BOOL_MSG']._serialized_end=378
+  _globals['_OUTCOMESTATUS']._serialized_start=380
+  _globals['_OUTCOMESTATUS']._serialized_end=443
 # @@protoc_insertion_point(module_scope)
diff --git a/src/druncschema/generic_pb2.pyi b/src/druncschema/generic_pb2.pyi
index 05ba34b..851a85a 100644
--- a/src/druncschema/generic_pb2.pyi
+++ b/src/druncschema/generic_pb2.pyi
@@ -7,17 +7,35 @@ from collections import abc as _abc
 from google.protobuf import descriptor as _descriptor
 from google.protobuf import message as _message
 from google.protobuf.internal import containers as _containers
+from google.protobuf.internal import enum_type_wrapper as _enum_type_wrapper
 import builtins as _builtins
 import sys
 import typing as _typing
 
-if sys.version_info >= (3, 10):
-    from typing import TypeAlias as _TypeAlias
+if sys.version_info >= (3, 11):
+    from typing import TypeAlias as _TypeAlias, Never as _Never
 else:
-    from typing_extensions import TypeAlias as _TypeAlias
+    from typing_extensions import TypeAlias as _TypeAlias, Never as _Never
 
 DESCRIPTOR: _descriptor.FileDescriptor
 
+class _OutcomeFlag:
+    ValueType = _typing.NewType("ValueType", _builtins.int)
+    V: _TypeAlias = ValueType  # noqa: Y015
+
+class _OutcomeFlagEnumTypeWrapper(_enum_type_wrapper._EnumTypeWrapper[_OutcomeFlag.ValueType], _builtins.type):
+    DESCRIPTOR: _descriptor.EnumDescriptor
+    SUCCESS: _OutcomeFlag.ValueType  # 0
+    FAIL: _OutcomeFlag.ValueType  # 1
+    UNKNOWN: _OutcomeFlag.ValueType  # 2
+
+class OutcomeFlag(_OutcomeFlag, metaclass=_OutcomeFlagEnumTypeWrapper): ...
+
+SUCCESS: OutcomeFlag.ValueType  # 0
+FAIL: OutcomeFlag.ValueType  # 1
+UNKNOWN: OutcomeFlag.ValueType  # 2
+Global___OutcomeFlag: _TypeAlias = OutcomeFlag  # noqa: Y015
+
 @_typing.final
 class Empty(_message.Message):
     DESCRIPTOR: _descriptor.Descriptor
@@ -25,6 +43,11 @@ class Empty(_message.Message):
     def __init__(
         self,
     ) -> None: ...
+    _HasFieldArgType: _TypeAlias = _Never  # noqa: Y015
+    def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
+    _ClearFieldArgType: _TypeAlias = _Never  # noqa: Y015
+    def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___Empty: _TypeAlias = Empty  # noqa: Y015
 
@@ -39,8 +62,11 @@ class PlainText(_message.Message):
         *,
         text: _builtins.str = ...,
     ) -> None: ...
+    _HasFieldArgType: _TypeAlias = _Never  # noqa: Y015
+    def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["text", b"text"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___PlainText: _TypeAlias = PlainText  # noqa: Y015
 
@@ -56,8 +82,11 @@ class PlainTextVector(_message.Message):
         *,
         text: _abc.Iterable[_builtins.str] | None = ...,
     ) -> None: ...
+    _HasFieldArgType: _TypeAlias = _Never  # noqa: Y015
+    def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["text", b"text"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___PlainTextVector: _TypeAlias = PlainTextVector  # noqa: Y015
 
@@ -73,8 +102,11 @@ class Stacktrace(_message.Message):
         *,
         text: _abc.Iterable[_builtins.str] | None = ...,
     ) -> None: ...
+    _HasFieldArgType: _TypeAlias = _Never  # noqa: Y015
+    def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["text", b"text"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___Stacktrace: _TypeAlias = Stacktrace  # noqa: Y015
 
@@ -96,8 +128,11 @@ class StringStringMap(_message.Message):
             key: _builtins.str = ...,
             value: _builtins.str = ...,
         ) -> None: ...
+        _HasFieldArgType: _TypeAlias = _Never  # noqa: Y015
+        def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
         _ClearFieldArgType: _TypeAlias = _typing.Literal["key", b"key", "value", b"value"]  # noqa: Y015
         def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+        def WhichOneof(self, oneof_group: _Never) -> None: ...
 
     MAP_FIELD_NUMBER: _builtins.int
     @_builtins.property
@@ -107,8 +142,11 @@ class StringStringMap(_message.Message):
         *,
         map: _abc.Mapping[_builtins.str, _builtins.str] | None = ...,
     ) -> None: ...
+    _HasFieldArgType: _TypeAlias = _Never  # noqa: Y015
+    def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["map", b"map"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___StringStringMap: _TypeAlias = StringStringMap  # noqa: Y015
 
@@ -123,8 +161,11 @@ class int_msg(_message.Message):
         *,
         value: _builtins.int = ...,
     ) -> None: ...
+    _HasFieldArgType: _TypeAlias = _Never  # noqa: Y015
+    def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["value", b"value"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___int_msg: _TypeAlias = int_msg  # noqa: Y015
 
@@ -139,8 +180,11 @@ class float_msg(_message.Message):
         *,
         value: _builtins.float = ...,
     ) -> None: ...
+    _HasFieldArgType: _TypeAlias = _Never  # noqa: Y015
+    def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["value", b"value"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___float_msg: _TypeAlias = float_msg  # noqa: Y015
 
@@ -155,8 +199,11 @@ class string_msg(_message.Message):
         *,
         value: _builtins.str = ...,
     ) -> None: ...
+    _HasFieldArgType: _TypeAlias = _Never  # noqa: Y015
+    def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["value", b"value"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___string_msg: _TypeAlias = string_msg  # noqa: Y015
 
@@ -171,7 +218,29 @@ class bool_msg(_message.Message):
         *,
         value: _builtins.bool = ...,
     ) -> None: ...
+    _HasFieldArgType: _TypeAlias = _Never  # noqa: Y015
+    def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["value", b"value"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___bool_msg: _TypeAlias = bool_msg  # noqa: Y015
+
+@_typing.final
+class OutcomeStatus(_message.Message):
+    DESCRIPTOR: _descriptor.Descriptor
+
+    FLAG_FIELD_NUMBER: _builtins.int
+    flag: Global___OutcomeFlag.ValueType
+    def __init__(
+        self,
+        *,
+        flag: Global___OutcomeFlag.ValueType = ...,
+    ) -> None: ...
+    _HasFieldArgType: _TypeAlias = _Never  # noqa: Y015
+    def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
+    _ClearFieldArgType: _TypeAlias = _typing.Literal["flag", b"flag"]  # noqa: Y015
+    def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
+
+Global___OutcomeStatus: _TypeAlias = OutcomeStatus  # noqa: Y015
diff --git a/src/druncschema/opmon/FSM_pb2.pyi b/src/druncschema/opmon/FSM_pb2.pyi
index 330a173..438f82f 100644
--- a/src/druncschema/opmon/FSM_pb2.pyi
+++ b/src/druncschema/opmon/FSM_pb2.pyi
@@ -9,10 +9,10 @@ import builtins as _builtins
 import sys
 import typing as _typing
 
-if sys.version_info >= (3, 10):
-    from typing import TypeAlias as _TypeAlias
+if sys.version_info >= (3, 11):
+    from typing import TypeAlias as _TypeAlias, Never as _Never
 else:
-    from typing_extensions import TypeAlias as _TypeAlias
+    from typing_extensions import TypeAlias as _TypeAlias, Never as _Never
 
 DESCRIPTOR: _descriptor.FileDescriptor
 
@@ -36,8 +36,11 @@ class FSMStatus(_message.Message):
         in_error: _builtins.bool = ...,
         included: _builtins.bool = ...,
     ) -> None: ...
+    _HasFieldArgType: _TypeAlias = _Never  # noqa: Y015
+    def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["in_error", b"in_error", "included", b"included", "state", b"state", "sub_state", b"sub_state"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___FSMStatus: _TypeAlias = FSMStatus  # noqa: Y015
 
@@ -52,7 +55,10 @@ class CommandTime(_message.Message):
         *,
         execution_time_ns: _builtins.int = ...,
     ) -> None: ...
+    _HasFieldArgType: _TypeAlias = _Never  # noqa: Y015
+    def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["execution_time_ns", b"execution_time_ns"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___CommandTime: _TypeAlias = CommandTime  # noqa: Y015
diff --git a/src/druncschema/opmon/generic_pb2.pyi b/src/druncschema/opmon/generic_pb2.pyi
index 68bfdfb..a199599 100644
--- a/src/druncschema/opmon/generic_pb2.pyi
+++ b/src/druncschema/opmon/generic_pb2.pyi
@@ -9,10 +9,10 @@ import builtins as _builtins
 import sys
 import typing as _typing
 
-if sys.version_info >= (3, 10):
-    from typing import TypeAlias as _TypeAlias
+if sys.version_info >= (3, 11):
+    from typing import TypeAlias as _TypeAlias, Never as _Never
 else:
-    from typing_extensions import TypeAlias as _TypeAlias
+    from typing_extensions import TypeAlias as _TypeAlias, Never as _Never
 
 DESCRIPTOR: _descriptor.FileDescriptor
 
@@ -48,7 +48,10 @@ class RunInfo(_message.Message):
         run_config_file: _builtins.str = ...,
         run_config_name: _builtins.str = ...,
     ) -> None: ...
+    _HasFieldArgType: _TypeAlias = _Never  # noqa: Y015
+    def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["disable_data_storage", b"disable_data_storage", "run_config_file", b"run_config_file", "run_config_name", b"run_config_name", "run_number", b"run_number", "run_time_at_start", b"run_time_at_start", "run_time_since_start", b"run_time_since_start", "run_type", b"run_type", "trigger_rate", b"trigger_rate"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___RunInfo: _TypeAlias = RunInfo  # noqa: Y015
diff --git a/src/druncschema/opmon/process_manager_pb2.pyi b/src/druncschema/opmon/process_manager_pb2.pyi
index 71566a8..301e43c 100644
--- a/src/druncschema/opmon/process_manager_pb2.pyi
+++ b/src/druncschema/opmon/process_manager_pb2.pyi
@@ -9,10 +9,10 @@ import builtins as _builtins
 import sys
 import typing as _typing
 
-if sys.version_info >= (3, 10):
-    from typing import TypeAlias as _TypeAlias
+if sys.version_info >= (3, 11):
+    from typing import TypeAlias as _TypeAlias, Never as _Never
 else:
-    from typing_extensions import TypeAlias as _TypeAlias
+    from typing_extensions import TypeAlias as _TypeAlias, Never as _Never
 
 DESCRIPTOR: _descriptor.FileDescriptor
 
@@ -33,7 +33,10 @@ class ProcessStatus(_message.Message):
         n_dead: _builtins.int = ...,
         n_session: _builtins.int = ...,
     ) -> None: ...
+    _HasFieldArgType: _TypeAlias = _Never  # noqa: Y015
+    def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["n_dead", b"n_dead", "n_running", b"n_running", "n_session", b"n_session"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___ProcessStatus: _TypeAlias = ProcessStatus  # noqa: Y015
diff --git a/src/druncschema/process_manager_pb2.py b/src/druncschema/process_manager_pb2.py
index de81d86..41eebe0 100644
--- a/src/druncschema/process_manager_pb2.py
+++ b/src/druncschema/process_manager_pb2.py
@@ -25,9 +25,10 @@
 from druncschema import request_response_pb2 as druncschema_dot_request__response__pb2
 from druncschema import description_pb2 as druncschema_dot_description__pb2
 from druncschema import token_pb2 as druncschema_dot_token__pb2
+from druncschema import generic_pb2 as druncschema_dot_generic__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\"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\"\xc6\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\x12\x12\n\x05\x63rash\x18\x06 \x01(\x08H\x00\x88\x01\x01\x42\x08\n\x06_crash\"\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\"\xb5\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\x12\x17\n\nremote_pid\x18\x06 \x01(\tH\x00\x88\x01\x01\"#\n\nStatusCode\x12\x0b\n\x07RUNNING\x10\x00\x12\x08\n\x04\x44\x45\x41\x44\x10\x01\x42\r\n\x0b_remote_pid\"\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\x1a\x19\x64runcschema/generic.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\"\xc6\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\x12\x12\n\x05\x63rash\x18\x06 \x01(\x08H\x00\x88\x01\x01\x42\x08\n\x06_crash\"\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\"\xb5\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\x12\x17\n\nremote_pid\x18\x06 \x01(\tH\x00\x88\x01\x01\"#\n\nStatusCode\x12\x0b\n\x07RUNNING\x10\x00\x12\x08\n\x04\x44\x45\x41\x44\x10\x01\x42\r\n\x0b_remote_pid\"\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\xd3\x07\n\x0eProcessManager\x12N\n\x08send_msg\x12\x1c.dunedaq.druncschema.Request\x1a\".dunedaq.druncschema.OutcomeStatus\"\x00\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)
@@ -36,42 +37,42 @@
   DESCRIPTOR._loaded_options = None
   _globals['_PROCESSDESCRIPTION_ENVENTRY']._loaded_options = None
   _globals['_PROCESSDESCRIPTION_ENVENTRY']._serialized_options = b'8\001'
-  _globals['_PROCESSRESTRICTION']._serialized_start=166
-  _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=1356
-  _globals['_PROCESSDESCRIPTION']._serialized_start=1359
-  _globals['_PROCESSDESCRIPTION']._serialized_end=1814
-  _globals['_PROCESSDESCRIPTION_STRINGLIST']._serialized_start=1699
-  _globals['_PROCESSDESCRIPTION_STRINGLIST']._serialized_end=1727
-  _globals['_PROCESSDESCRIPTION_EXECANDARGS']._serialized_start=1729
-  _globals['_PROCESSDESCRIPTION_EXECANDARGS']._serialized_end=1770
-  _globals['_PROCESSDESCRIPTION_ENVENTRY']._serialized_start=1772
-  _globals['_PROCESSDESCRIPTION_ENVENTRY']._serialized_end=1814
-  _globals['_PROCESSINSTANCE']._serialized_start=1817
-  _globals['_PROCESSINSTANCE']._serialized_end=2254
-  _globals['_PROCESSINSTANCE_STATUSCODE']._serialized_start=2204
-  _globals['_PROCESSINSTANCE_STATUSCODE']._serialized_end=2239
-  _globals['_PROCESSINSTANCELIST']._serialized_start=2257
-  _globals['_PROCESSINSTANCELIST']._serialized_end=2454
-  _globals['_BOOTREQUEST']._serialized_start=2457
-  _globals['_BOOTREQUEST']._serialized_end=2685
-  _globals['_PROCESSMANAGER']._serialized_start=2688
-  _globals['_PROCESSMANAGER']._serialized_end=3587
+  _globals['_PROCESSRESTRICTION']._serialized_start=193
+  _globals['_PROCESSRESTRICTION']._serialized_end=304
+  _globals['_COMMANDNOTIFICATIONMESSAGE']._serialized_start=306
+  _globals['_COMMANDNOTIFICATIONMESSAGE']._serialized_end=365
+  _globals['_GENERICNOTIFICATIONMESSAGE']._serialized_start=367
+  _globals['_GENERICNOTIFICATIONMESSAGE']._serialized_end=412
+  _globals['_EXCEPTIONNOTIFICATION']._serialized_start=415
+  _globals['_EXCEPTIONNOTIFICATION']._serialized_end=616
+  _globals['_EXCEPTIONNOTIFICATION_STACKLINE']._serialized_start=551
+  _globals['_EXCEPTIONNOTIFICATION_STACKLINE']._serialized_end=616
+  _globals['_LOGREQUEST']._serialized_start=619
+  _globals['_LOGREQUEST']._serialized_end=757
+  _globals['_LOGLINES']._serialized_start=760
+  _globals['_LOGLINES']._serialized_end=955
+  _globals['_PROCESSUUID']._serialized_start=957
+  _globals['_PROCESSUUID']._serialized_end=984
+  _globals['_PROCESSMETADATA']._serialized_start=987
+  _globals['_PROCESSMETADATA']._serialized_end=1182
+  _globals['_PROCESSQUERY']._serialized_start=1185
+  _globals['_PROCESSQUERY']._serialized_end=1383
+  _globals['_PROCESSDESCRIPTION']._serialized_start=1386
+  _globals['_PROCESSDESCRIPTION']._serialized_end=1841
+  _globals['_PROCESSDESCRIPTION_STRINGLIST']._serialized_start=1726
+  _globals['_PROCESSDESCRIPTION_STRINGLIST']._serialized_end=1754
+  _globals['_PROCESSDESCRIPTION_EXECANDARGS']._serialized_start=1756
+  _globals['_PROCESSDESCRIPTION_EXECANDARGS']._serialized_end=1797
+  _globals['_PROCESSDESCRIPTION_ENVENTRY']._serialized_start=1799
+  _globals['_PROCESSDESCRIPTION_ENVENTRY']._serialized_end=1841
+  _globals['_PROCESSINSTANCE']._serialized_start=1844
+  _globals['_PROCESSINSTANCE']._serialized_end=2281
+  _globals['_PROCESSINSTANCE_STATUSCODE']._serialized_start=2231
+  _globals['_PROCESSINSTANCE_STATUSCODE']._serialized_end=2266
+  _globals['_PROCESSINSTANCELIST']._serialized_start=2284
+  _globals['_PROCESSINSTANCELIST']._serialized_end=2481
+  _globals['_BOOTREQUEST']._serialized_start=2484
+  _globals['_BOOTREQUEST']._serialized_end=2712
+  _globals['_PROCESSMANAGER']._serialized_start=2715
+  _globals['_PROCESSMANAGER']._serialized_end=3694
 # @@protoc_insertion_point(module_scope)
diff --git a/src/druncschema/process_manager_pb2.pyi b/src/druncschema/process_manager_pb2.pyi
index 757500e..67c12ec 100644
--- a/src/druncschema/process_manager_pb2.pyi
+++ b/src/druncschema/process_manager_pb2.pyi
@@ -14,10 +14,10 @@ import builtins as _builtins
 import sys
 import typing as _typing
 
-if sys.version_info >= (3, 10):
-    from typing import TypeAlias as _TypeAlias
+if sys.version_info >= (3, 11):
+    from typing import TypeAlias as _TypeAlias, Never as _Never
 else:
-    from typing_extensions import TypeAlias as _TypeAlias
+    from typing_extensions import TypeAlias as _TypeAlias, Never as _Never
 
 DESCRIPTOR: _descriptor.FileDescriptor
 
@@ -64,8 +64,11 @@ class CommandNotificationMessage(_message.Message):
         user: _builtins.str = ...,
         command: _builtins.str = ...,
     ) -> None: ...
+    _HasFieldArgType: _TypeAlias = _Never  # noqa: Y015
+    def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["command", b"command", "user", b"user"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___CommandNotificationMessage: _TypeAlias = CommandNotificationMessage  # noqa: Y015
 
@@ -80,8 +83,11 @@ class GenericNotificationMessage(_message.Message):
         *,
         message: _builtins.str = ...,
     ) -> None: ...
+    _HasFieldArgType: _TypeAlias = _Never  # noqa: Y015
+    def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["message", b"message"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___GenericNotificationMessage: _TypeAlias = GenericNotificationMessage  # noqa: Y015
 
@@ -106,8 +112,11 @@ class ExceptionNotification(_message.Message):
             line_number: _builtins.str = ...,
             file: _builtins.str = ...,
         ) -> None: ...
+        _HasFieldArgType: _TypeAlias = _Never  # noqa: Y015
+        def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
         _ClearFieldArgType: _TypeAlias = _typing.Literal["file", b"file", "line_number", b"line_number", "line_text", b"line_text"]  # noqa: Y015
         def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+        def WhichOneof(self, oneof_group: _Never) -> None: ...
 
     ERROR_TEXT_FIELD_NUMBER: _builtins.int
     STACK_TRACE_FIELD_NUMBER: _builtins.int
@@ -120,8 +129,11 @@ class ExceptionNotification(_message.Message):
         error_text: _builtins.str = ...,
         stack_trace: _abc.Iterable[Global___ExceptionNotification.StackLine] | None = ...,
     ) -> None: ...
+    _HasFieldArgType: _TypeAlias = _Never  # noqa: Y015
+    def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["error_text", b"error_text", "stack_trace", b"stack_trace"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___ExceptionNotification: _TypeAlias = ExceptionNotification  # noqa: Y015
 
@@ -148,6 +160,7 @@ class LogRequest(_message.Message):
     def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["how_far", b"how_far", "query", b"query", "token", b"token"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___LogRequest: _TypeAlias = LogRequest  # noqa: Y015
 
@@ -181,6 +194,7 @@ class LogLines(_message.Message):
     def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["flag", b"flag", "lines", b"lines", "name", b"name", "token", b"token", "uuid", b"uuid"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___LogLines: _TypeAlias = LogLines  # noqa: Y015
 
@@ -195,8 +209,11 @@ class ProcessUUID(_message.Message):
         *,
         uuid: _builtins.str = ...,
     ) -> None: ...
+    _HasFieldArgType: _TypeAlias = _Never  # noqa: Y015
+    def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["uuid", b"uuid"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___ProcessUUID: _TypeAlias = ProcessUUID  # noqa: Y015
 
@@ -297,8 +314,11 @@ class ProcessDescription(_message.Message):
             *,
             values: _abc.Iterable[_builtins.str] | None = ...,
         ) -> None: ...
+        _HasFieldArgType: _TypeAlias = _Never  # noqa: Y015
+        def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
         _ClearFieldArgType: _TypeAlias = _typing.Literal["values", b"values"]  # noqa: Y015
         def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+        def WhichOneof(self, oneof_group: _Never) -> None: ...
 
     @_typing.final
     class ExecAndArgs(_message.Message):
@@ -315,8 +335,11 @@ class ProcessDescription(_message.Message):
             exec: _builtins.str = ...,
             args: _abc.Iterable[_builtins.str] | None = ...,
         ) -> None: ...
+        _HasFieldArgType: _TypeAlias = _Never  # noqa: Y015
+        def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
         _ClearFieldArgType: _TypeAlias = _typing.Literal["args", b"args", "exec", b"exec"]  # noqa: Y015
         def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+        def WhichOneof(self, oneof_group: _Never) -> None: ...
 
     @_typing.final
     class EnvEntry(_message.Message):
@@ -332,8 +355,11 @@ class ProcessDescription(_message.Message):
             key: _builtins.str = ...,
             value: _builtins.str = ...,
         ) -> None: ...
+        _HasFieldArgType: _TypeAlias = _Never  # noqa: Y015
+        def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
         _ClearFieldArgType: _TypeAlias = _typing.Literal["key", b"key", "value", b"value"]  # noqa: Y015
         def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+        def WhichOneof(self, oneof_group: _Never) -> None: ...
 
     METADATA_FIELD_NUMBER: _builtins.int
     ENV_FIELD_NUMBER: _builtins.int
@@ -362,6 +388,7 @@ class ProcessDescription(_message.Message):
     def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["env", b"env", "executable_and_arguments", b"executable_and_arguments", "metadata", b"metadata", "process_execution_directory", b"process_execution_directory", "process_logs_path", b"process_logs_path"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___ProcessDescription: _TypeAlias = ProcessDescription  # noqa: Y015
 
@@ -443,6 +470,7 @@ class ProcessInstanceList(_message.Message):
     def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["flag", b"flag", "name", b"name", "token", b"token", "values", b"values"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___ProcessInstanceList: _TypeAlias = ProcessInstanceList  # noqa: Y015
 
@@ -470,5 +498,6 @@ class BootRequest(_message.Message):
     def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["process_description", b"process_description", "process_restriction", b"process_restriction", "token", b"token"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___BootRequest: _TypeAlias = BootRequest  # noqa: Y015
diff --git a/src/druncschema/process_manager_pb2_grpc.py b/src/druncschema/process_manager_pb2_grpc.py
index 650a826..f3e7893 100644
--- a/src/druncschema/process_manager_pb2_grpc.py
+++ b/src/druncschema/process_manager_pb2_grpc.py
@@ -4,6 +4,7 @@
 import warnings
 
 from druncschema import description_pb2 as druncschema_dot_description__pb2
+from druncschema import generic_pb2 as druncschema_dot_generic__pb2
 from druncschema import process_manager_pb2 as druncschema_dot_process__manager__pb2
 from druncschema import request_response_pb2 as druncschema_dot_request__response__pb2
 
@@ -36,6 +37,11 @@ def __init__(self, channel):
         Args:
             channel: A grpc.Channel.
         """
+        self.send_msg = channel.unary_unary(
+                '/dunedaq.druncschema.process_manager.ProcessManager/send_msg',
+                request_serializer=druncschema_dot_request__response__pb2.Request.SerializeToString,
+                response_deserializer=druncschema_dot_generic__pb2.OutcomeStatus.FromString,
+                _registered_method=True)
         self.describe = channel.unary_unary(
                 '/dunedaq.druncschema.process_manager.ProcessManager/describe',
                 request_serializer=druncschema_dot_request__response__pb2.Request.SerializeToString,
@@ -81,6 +87,12 @@ def __init__(self, channel):
 class ProcessManagerServicer(object):
     """Missing associated documentation comment in .proto file."""
 
+    def send_msg(self, request, context):
+        """Missing associated documentation comment in .proto file."""
+        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+        context.set_details('Method not implemented!')
+        raise NotImplementedError('Method not implemented!')
+
     def describe(self, request, context):
         """Missing associated documentation comment in .proto file."""
         context.set_code(grpc.StatusCode.UNIMPLEMENTED)
@@ -132,6 +144,11 @@ def logs(self, request, context):
 
 def add_ProcessManagerServicer_to_server(servicer, server):
     rpc_method_handlers = {
+            'send_msg': grpc.unary_unary_rpc_method_handler(
+                    servicer.send_msg,
+                    request_deserializer=druncschema_dot_request__response__pb2.Request.FromString,
+                    response_serializer=druncschema_dot_generic__pb2.OutcomeStatus.SerializeToString,
+            ),
             'describe': grpc.unary_unary_rpc_method_handler(
                     servicer.describe,
                     request_deserializer=druncschema_dot_request__response__pb2.Request.FromString,
@@ -183,6 +200,33 @@ def add_ProcessManagerServicer_to_server(servicer, server):
 class ProcessManager(object):
     """Missing associated documentation comment in .proto file."""
 
+    @staticmethod
+    def send_msg(request,
+            target,
+            options=(),
+            channel_credentials=None,
+            call_credentials=None,
+            insecure=False,
+            compression=None,
+            wait_for_ready=None,
+            timeout=None,
+            metadata=None):
+        return grpc.experimental.unary_unary(
+            request,
+            target,
+            '/dunedaq.druncschema.process_manager.ProcessManager/send_msg',
+            druncschema_dot_request__response__pb2.Request.SerializeToString,
+            druncschema_dot_generic__pb2.OutcomeStatus.FromString,
+            options,
+            channel_credentials,
+            insecure,
+            call_credentials,
+            compression,
+            wait_for_ready,
+            timeout,
+            metadata,
+            _registered_method=True)
+
     @staticmethod
     def describe(request,
             target,
diff --git a/src/druncschema/session_manager_pb2.pyi b/src/druncschema/session_manager_pb2.pyi
index f3c45d3..27d92db 100644
--- a/src/druncschema/session_manager_pb2.pyi
+++ b/src/druncschema/session_manager_pb2.pyi
@@ -13,10 +13,10 @@ import builtins as _builtins
 import sys
 import typing as _typing
 
-if sys.version_info >= (3, 10):
-    from typing import TypeAlias as _TypeAlias
+if sys.version_info >= (3, 11):
+    from typing import TypeAlias as _TypeAlias, Never as _Never
 else:
-    from typing_extensions import TypeAlias as _TypeAlias
+    from typing_extensions import TypeAlias as _TypeAlias, Never as _Never
 
 DESCRIPTOR: _descriptor.FileDescriptor
 
@@ -34,8 +34,11 @@ class ConfigKey(_message.Message):
         file: _builtins.str = ...,
         session_id: _builtins.str = ...,
     ) -> None: ...
+    _HasFieldArgType: _TypeAlias = _Never  # noqa: Y015
+    def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["file", b"file", "session_id", b"session_id"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___ConfigKey: _TypeAlias = ConfigKey  # noqa: Y015
 
@@ -65,6 +68,7 @@ class AllConfigKeys(_message.Message):
     def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["config_keys", b"config_keys", "flag", b"flag", "name", b"name", "token", b"token"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___AllConfigKeys: _TypeAlias = AllConfigKeys  # noqa: Y015
 
@@ -90,6 +94,7 @@ class ActiveSession(_message.Message):
     def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["config_key", b"config_key", "name", b"name", "user", b"user"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___ActiveSession: _TypeAlias = ActiveSession  # noqa: Y015
 
@@ -119,5 +124,6 @@ class AllActiveSessions(_message.Message):
     def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["active_sessions", b"active_sessions", "flag", b"flag", "name", b"name", "token", b"token"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___AllActiveSessions: _TypeAlias = AllActiveSessions  # noqa: Y015
diff --git a/src/druncschema/token_pb2.pyi b/src/druncschema/token_pb2.pyi
index ef159d3..a3c7f81 100644
--- a/src/druncschema/token_pb2.pyi
+++ b/src/druncschema/token_pb2.pyi
@@ -9,10 +9,10 @@ import builtins as _builtins
 import sys
 import typing as _typing
 
-if sys.version_info >= (3, 10):
-    from typing import TypeAlias as _TypeAlias
+if sys.version_info >= (3, 11):
+    from typing import TypeAlias as _TypeAlias, Never as _Never
 else:
-    from typing_extensions import TypeAlias as _TypeAlias
+    from typing_extensions import TypeAlias as _TypeAlias, Never as _Never
 
 DESCRIPTOR: _descriptor.FileDescriptor
 
@@ -30,7 +30,10 @@ class Token(_message.Message):
         token: _builtins.str = ...,
         user_name: _builtins.str = ...,
     ) -> None: ...
+    _HasFieldArgType: _TypeAlias = _Never  # noqa: Y015
+    def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["token", b"token", "user_name", b"user_name"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___Token: _TypeAlias = Token  # noqa: Y015