This is an automated email from the ASF dual-hosted git repository.
yasithdev pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/airavata.git
The following commit(s) were added to refs/heads/master by this push:
new 70ff6c249c Remove dead messaging_events.proto and its orphaned SDK
stubs (#673)
70ff6c249c is described below
commit 70ff6c249c72301e43334469078682cb9fc46d38
Author: Yasith Jayawardana <[email protected]>
AuthorDate: Sat Jun 13 01:19:58 2026 -0400
Remove dead messaging_events.proto and its orphaned SDK stubs (#673)
messaging_events.proto (16 Thrift-era event messages:
Experiment/Process/Task/Job
status-change and submit/terminate events, plus the generic Message
envelope) is
imported by no other proto and referenced by no hand-written Java/Python —
its
only consumer, KafkaProxyService, was removed when orchestration moved to
the
DB-transactional executor. Remove it and its three committed SDK stubs.
Protos
are glob-compiled, so the reactor regenerates cleanly without it.
---
.../model/messaging/messaging_events.proto | 142 --------------
.../model/messaging/messaging_events_pb2.py | 73 --------
.../model/messaging/messaging_events_pb2.pyi | 204 ---------------------
.../model/messaging/messaging_events_pb2_grpc.py | 24 ---
4 files changed, 443 deletions(-)
diff --git
a/airavata-api/src/main/proto/org/apache/airavata/model/messaging/messaging_events.proto
b/airavata-api/src/main/proto/org/apache/airavata/model/messaging/messaging_events.proto
deleted file mode 100644
index 4de9b247c6..0000000000
---
a/airavata-api/src/main/proto/org/apache/airavata/model/messaging/messaging_events.proto
+++ /dev/null
@@ -1,142 +0,0 @@
-// Licensed to the Apache Software Foundation (ASF) under one
-// or more contributor license agreements. See the NOTICE file
-// distributed with this work for additional information
-// regarding copyright ownership. The ASF licenses this file
-// to you under the Apache License, Version 2.0 (the
-// "License"); you may not use this file except in compliance
-// with the License. You may obtain a copy of the License at
-//
-// http://www.apache.org/licenses/LICENSE-2.0
-//
-// Unless required by applicable law or agreed to in writing,
-// software distributed under the License is distributed on an
-// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-// KIND, either express or implied. See the License for the
-// specific language governing permissions and limitations
-// under the License.
-
-syntax = "proto3";
-
-package org.apache.airavata.model.messaging.event;
-
-option java_package = "org.apache.airavata.model.messaging.event.proto";
-option java_multiple_files = true;
-
-import "org/apache/airavata/model/status/status.proto";
-import "org/apache/airavata/model/application/io/application_io.proto";
-
-enum MessageLevel {
- MESSAGE_LEVEL_UNKNOWN = 0;
- INFO = 1;
- DEBUG = 2;
- ERROR = 3;
- ACK = 4;
-}
-
-enum MessageType {
- MESSAGE_TYPE_UNKNOWN = 0;
- EXPERIMENT = 1;
- EXPERIMENT_CANCEL = 2;
- TASK = 3;
- PROCESS = 4;
- JOB = 5;
- LAUNCHPROCESS = 6;
- TERMINATEPROCESS = 7;
- PROCESSOUTPUT = 8;
- DB_EVENT = 9;
- INTERMEDIATE_OUTPUTS = 10;
-}
-
-message ExperimentStatusChangeEvent {
- org.apache.airavata.model.status.ExperimentState state = 1;
- string experiment_id = 2;
- string gateway_id = 3;
-}
-
-message ProcessIdentifier {
- string process_id = 1;
- string experiment_id = 2;
- string gateway_id = 3;
-}
-
-message TaskIdentifier {
- string task_id = 1;
- string process_id = 2;
- string experiment_id = 3;
- string gateway_id = 4;
-}
-
-message TaskStatusChangeEvent {
- org.apache.airavata.model.status.TaskState state = 1;
- TaskIdentifier task_identity = 2;
-}
-
-message TaskStatusChangeRequestEvent {
- org.apache.airavata.model.status.TaskState state = 1;
- TaskIdentifier task_identity = 2;
-}
-
-message ProcessStatusChangeEvent {
- org.apache.airavata.model.status.ProcessState state = 1;
- ProcessIdentifier process_identity = 2;
-}
-
-message ProcessStatusChangeRequestEvent {
- org.apache.airavata.model.status.ProcessState state = 1;
- ProcessIdentifier process_identity = 2;
-}
-
-message TaskOutputChangeEvent {
- repeated org.apache.airavata.model.application.io.OutputDataObjectType
output = 1;
- TaskIdentifier task_identity = 2;
-}
-
-message JobIdentifier {
- string job_id = 1;
- string task_id = 2;
- string process_id = 3;
- string experiment_id = 4;
- string gateway_id = 5;
-}
-
-message ExperimentSubmitEvent {
- string experiment_id = 1;
- string gateway_id = 2;
-}
-
-message ProcessSubmitEvent {
- string process_id = 1;
- string gateway_id = 2;
- string experiment_id = 3;
- string token_id = 4;
-}
-
-message ProcessTerminateEvent {
- string process_id = 1;
- string gateway_id = 2;
- string token_id = 3;
-}
-
-message JobStatusChangeEvent {
- org.apache.airavata.model.status.JobState state = 1;
- JobIdentifier job_identity = 2;
-}
-
-message JobStatusChangeRequestEvent {
- org.apache.airavata.model.status.JobState state = 1;
- JobIdentifier job_identity = 2;
-}
-
-message ExperimentIntermediateOutputsEvent {
- string experiment_id = 1;
- string gateway_id = 2;
- repeated string output_names = 3;
-}
-
-message Message {
- bytes event = 1;
- string message_id = 2;
- MessageType message_type = 3;
- int64 updated_time = 4;
- MessageLevel message_level = 5;
-}
diff --git
a/airavata-python-sdk/airavata_sdk/generated/org/apache/airavata/model/messaging/messaging_events_pb2.py
b/airavata-python-sdk/airavata_sdk/generated/org/apache/airavata/model/messaging/messaging_events_pb2.py
deleted file mode 100644
index 61361645b6..0000000000
---
a/airavata-python-sdk/airavata_sdk/generated/org/apache/airavata/model/messaging/messaging_events_pb2.py
+++ /dev/null
@@ -1,73 +0,0 @@
-# -*- coding: utf-8 -*-
-# Generated by the protocol buffer compiler. DO NOT EDIT!
-# NO CHECKED-IN PROTOBUF GENCODE
-# source: org/apache/airavata/model/messaging/messaging_events.proto
-# 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
-from google.protobuf import runtime_version as _runtime_version
-from google.protobuf import symbol_database as _symbol_database
-from google.protobuf.internal import builder as _builder
-_runtime_version.ValidateProtobufRuntimeVersion(
- _runtime_version.Domain.PUBLIC,
- 6,
- 31,
- 1,
- '',
- 'org/apache/airavata/model/messaging/messaging_events.proto'
-)
-# @@protoc_insertion_point(imports)
-
-_sym_db = _symbol_database.Default()
-
-
-from org.apache.airavata.model.status import status_pb2 as
org_dot_apache_dot_airavata_dot_model_dot_status_dot_status__pb2
-from org.apache.airavata.model.application.io import application_io_pb2 as
org_dot_apache_dot_airavata_dot_model_dot_application_dot_io_dot_application__io__pb2
-
-
-DESCRIPTOR =
_descriptor_pool.Default().AddSerializedFile(b'\n:org/apache/airavata/model/messaging/messaging_events.proto\x12)org.apache.airavata.model.messaging.event\x1a-org/apache/airavata/model/status/status.proto\x1a=org/apache/airavata/model/application/io/application_io.proto\"\x8a\x01\n\x1b\x45xperimentStatusChangeEvent\x12@\n\x05state\x18\x01
\x01(\x0e\x32\x31.org.apache.airavata.model.status.ExperimentState\x12\x15\n\rexperiment_id\x18\x02
\x01(\t\x12\x12\n\ngateway_id\x18\x03 [...]
-
-_globals = globals()
-_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals)
-_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR,
'org.apache.airavata.model.messaging.messaging_events_pb2', _globals)
-if not _descriptor._USE_C_DESCRIPTORS:
- _globals['DESCRIPTOR']._loaded_options = None
- _globals['DESCRIPTOR']._serialized_options =
b'\n/org.apache.airavata.model.messaging.event.protoP\001'
- _globals['_MESSAGELEVEL']._serialized_start=2468
- _globals['_MESSAGELEVEL']._serialized_end=2550
- _globals['_MESSAGETYPE']._serialized_start=2553
- _globals['_MESSAGETYPE']._serialized_end=2763
- _globals['_EXPERIMENTSTATUSCHANGEEVENT']._serialized_start=216
- _globals['_EXPERIMENTSTATUSCHANGEEVENT']._serialized_end=354
- _globals['_PROCESSIDENTIFIER']._serialized_start=356
- _globals['_PROCESSIDENTIFIER']._serialized_end=438
- _globals['_TASKIDENTIFIER']._serialized_start=440
- _globals['_TASKIDENTIFIER']._serialized_end=536
- _globals['_TASKSTATUSCHANGEEVENT']._serialized_start=539
- _globals['_TASKSTATUSCHANGEEVENT']._serialized_end=704
- _globals['_TASKSTATUSCHANGEREQUESTEVENT']._serialized_start=707
- _globals['_TASKSTATUSCHANGEREQUESTEVENT']._serialized_end=879
- _globals['_PROCESSSTATUSCHANGEEVENT']._serialized_start=882
- _globals['_PROCESSSTATUSCHANGEEVENT']._serialized_end=1059
- _globals['_PROCESSSTATUSCHANGEREQUESTEVENT']._serialized_start=1062
- _globals['_PROCESSSTATUSCHANGEREQUESTEVENT']._serialized_end=1246
- _globals['_TASKOUTPUTCHANGEEVENT']._serialized_start=1249
- _globals['_TASKOUTPUTCHANGEEVENT']._serialized_end=1434
- _globals['_JOBIDENTIFIER']._serialized_start=1436
- _globals['_JOBIDENTIFIER']._serialized_end=1547
- _globals['_EXPERIMENTSUBMITEVENT']._serialized_start=1549
- _globals['_EXPERIMENTSUBMITEVENT']._serialized_end=1615
- _globals['_PROCESSSUBMITEVENT']._serialized_start=1617
- _globals['_PROCESSSUBMITEVENT']._serialized_end=1718
- _globals['_PROCESSTERMINATEEVENT']._serialized_start=1720
- _globals['_PROCESSTERMINATEEVENT']._serialized_end=1801
- _globals['_JOBSTATUSCHANGEEVENT']._serialized_start=1804
- _globals['_JOBSTATUSCHANGEEVENT']._serialized_end=1965
- _globals['_JOBSTATUSCHANGEREQUESTEVENT']._serialized_start=1968
- _globals['_JOBSTATUSCHANGEREQUESTEVENT']._serialized_end=2136
- _globals['_EXPERIMENTINTERMEDIATEOUTPUTSEVENT']._serialized_start=2138
- _globals['_EXPERIMENTINTERMEDIATEOUTPUTSEVENT']._serialized_end=2239
- _globals['_MESSAGE']._serialized_start=2242
- _globals['_MESSAGE']._serialized_end=2466
-# @@protoc_insertion_point(module_scope)
diff --git
a/airavata-python-sdk/airavata_sdk/generated/org/apache/airavata/model/messaging/messaging_events_pb2.pyi
b/airavata-python-sdk/airavata_sdk/generated/org/apache/airavata/model/messaging/messaging_events_pb2.pyi
deleted file mode 100644
index 0e2b9a833d..0000000000
---
a/airavata-python-sdk/airavata_sdk/generated/org/apache/airavata/model/messaging/messaging_events_pb2.pyi
+++ /dev/null
@@ -1,204 +0,0 @@
-from org.apache.airavata.model.status import status_pb2 as _status_pb2
-from org.apache.airavata.model.application.io import application_io_pb2 as
_application_io_pb2
-from google.protobuf.internal import containers as _containers
-from google.protobuf.internal import enum_type_wrapper as _enum_type_wrapper
-from google.protobuf import descriptor as _descriptor
-from google.protobuf import message as _message
-from collections.abc import Iterable as _Iterable, Mapping as _Mapping
-from typing import ClassVar as _ClassVar, Optional as _Optional, Union as
_Union
-
-DESCRIPTOR: _descriptor.FileDescriptor
-
-class MessageLevel(int, metaclass=_enum_type_wrapper.EnumTypeWrapper):
- __slots__ = ()
- MESSAGE_LEVEL_UNKNOWN: _ClassVar[MessageLevel]
- INFO: _ClassVar[MessageLevel]
- DEBUG: _ClassVar[MessageLevel]
- ERROR: _ClassVar[MessageLevel]
- ACK: _ClassVar[MessageLevel]
-
-class MessageType(int, metaclass=_enum_type_wrapper.EnumTypeWrapper):
- __slots__ = ()
- MESSAGE_TYPE_UNKNOWN: _ClassVar[MessageType]
- EXPERIMENT: _ClassVar[MessageType]
- EXPERIMENT_CANCEL: _ClassVar[MessageType]
- TASK: _ClassVar[MessageType]
- PROCESS: _ClassVar[MessageType]
- JOB: _ClassVar[MessageType]
- LAUNCHPROCESS: _ClassVar[MessageType]
- TERMINATEPROCESS: _ClassVar[MessageType]
- PROCESSOUTPUT: _ClassVar[MessageType]
- DB_EVENT: _ClassVar[MessageType]
- INTERMEDIATE_OUTPUTS: _ClassVar[MessageType]
-MESSAGE_LEVEL_UNKNOWN: MessageLevel
-INFO: MessageLevel
-DEBUG: MessageLevel
-ERROR: MessageLevel
-ACK: MessageLevel
-MESSAGE_TYPE_UNKNOWN: MessageType
-EXPERIMENT: MessageType
-EXPERIMENT_CANCEL: MessageType
-TASK: MessageType
-PROCESS: MessageType
-JOB: MessageType
-LAUNCHPROCESS: MessageType
-TERMINATEPROCESS: MessageType
-PROCESSOUTPUT: MessageType
-DB_EVENT: MessageType
-INTERMEDIATE_OUTPUTS: MessageType
-
-class ExperimentStatusChangeEvent(_message.Message):
- __slots__ = ("state", "experiment_id", "gateway_id")
- STATE_FIELD_NUMBER: _ClassVar[int]
- EXPERIMENT_ID_FIELD_NUMBER: _ClassVar[int]
- GATEWAY_ID_FIELD_NUMBER: _ClassVar[int]
- state: _status_pb2.ExperimentState
- experiment_id: str
- gateway_id: str
- def __init__(self, state: _Optional[_Union[_status_pb2.ExperimentState,
str]] = ..., experiment_id: _Optional[str] = ..., gateway_id: _Optional[str] =
...) -> None: ...
-
-class ProcessIdentifier(_message.Message):
- __slots__ = ("process_id", "experiment_id", "gateway_id")
- PROCESS_ID_FIELD_NUMBER: _ClassVar[int]
- EXPERIMENT_ID_FIELD_NUMBER: _ClassVar[int]
- GATEWAY_ID_FIELD_NUMBER: _ClassVar[int]
- process_id: str
- experiment_id: str
- gateway_id: str
- def __init__(self, process_id: _Optional[str] = ..., experiment_id:
_Optional[str] = ..., gateway_id: _Optional[str] = ...) -> None: ...
-
-class TaskIdentifier(_message.Message):
- __slots__ = ("task_id", "process_id", "experiment_id", "gateway_id")
- TASK_ID_FIELD_NUMBER: _ClassVar[int]
- PROCESS_ID_FIELD_NUMBER: _ClassVar[int]
- EXPERIMENT_ID_FIELD_NUMBER: _ClassVar[int]
- GATEWAY_ID_FIELD_NUMBER: _ClassVar[int]
- task_id: str
- process_id: str
- experiment_id: str
- gateway_id: str
- def __init__(self, task_id: _Optional[str] = ..., process_id:
_Optional[str] = ..., experiment_id: _Optional[str] = ..., gateway_id:
_Optional[str] = ...) -> None: ...
-
-class TaskStatusChangeEvent(_message.Message):
- __slots__ = ("state", "task_identity")
- STATE_FIELD_NUMBER: _ClassVar[int]
- TASK_IDENTITY_FIELD_NUMBER: _ClassVar[int]
- state: _status_pb2.TaskState
- task_identity: TaskIdentifier
- def __init__(self, state: _Optional[_Union[_status_pb2.TaskState, str]] =
..., task_identity: _Optional[_Union[TaskIdentifier, _Mapping]] = ...) -> None:
...
-
-class TaskStatusChangeRequestEvent(_message.Message):
- __slots__ = ("state", "task_identity")
- STATE_FIELD_NUMBER: _ClassVar[int]
- TASK_IDENTITY_FIELD_NUMBER: _ClassVar[int]
- state: _status_pb2.TaskState
- task_identity: TaskIdentifier
- def __init__(self, state: _Optional[_Union[_status_pb2.TaskState, str]] =
..., task_identity: _Optional[_Union[TaskIdentifier, _Mapping]] = ...) -> None:
...
-
-class ProcessStatusChangeEvent(_message.Message):
- __slots__ = ("state", "process_identity")
- STATE_FIELD_NUMBER: _ClassVar[int]
- PROCESS_IDENTITY_FIELD_NUMBER: _ClassVar[int]
- state: _status_pb2.ProcessState
- process_identity: ProcessIdentifier
- def __init__(self, state: _Optional[_Union[_status_pb2.ProcessState, str]]
= ..., process_identity: _Optional[_Union[ProcessIdentifier, _Mapping]] = ...)
-> None: ...
-
-class ProcessStatusChangeRequestEvent(_message.Message):
- __slots__ = ("state", "process_identity")
- STATE_FIELD_NUMBER: _ClassVar[int]
- PROCESS_IDENTITY_FIELD_NUMBER: _ClassVar[int]
- state: _status_pb2.ProcessState
- process_identity: ProcessIdentifier
- def __init__(self, state: _Optional[_Union[_status_pb2.ProcessState, str]]
= ..., process_identity: _Optional[_Union[ProcessIdentifier, _Mapping]] = ...)
-> None: ...
-
-class TaskOutputChangeEvent(_message.Message):
- __slots__ = ("output", "task_identity")
- OUTPUT_FIELD_NUMBER: _ClassVar[int]
- TASK_IDENTITY_FIELD_NUMBER: _ClassVar[int]
- output:
_containers.RepeatedCompositeFieldContainer[_application_io_pb2.OutputDataObjectType]
- task_identity: TaskIdentifier
- def __init__(self, output:
_Optional[_Iterable[_Union[_application_io_pb2.OutputDataObjectType,
_Mapping]]] = ..., task_identity: _Optional[_Union[TaskIdentifier, _Mapping]] =
...) -> None: ...
-
-class JobIdentifier(_message.Message):
- __slots__ = ("job_id", "task_id", "process_id", "experiment_id",
"gateway_id")
- JOB_ID_FIELD_NUMBER: _ClassVar[int]
- TASK_ID_FIELD_NUMBER: _ClassVar[int]
- PROCESS_ID_FIELD_NUMBER: _ClassVar[int]
- EXPERIMENT_ID_FIELD_NUMBER: _ClassVar[int]
- GATEWAY_ID_FIELD_NUMBER: _ClassVar[int]
- job_id: str
- task_id: str
- process_id: str
- experiment_id: str
- gateway_id: str
- def __init__(self, job_id: _Optional[str] = ..., task_id: _Optional[str] =
..., process_id: _Optional[str] = ..., experiment_id: _Optional[str] = ...,
gateway_id: _Optional[str] = ...) -> None: ...
-
-class ExperimentSubmitEvent(_message.Message):
- __slots__ = ("experiment_id", "gateway_id")
- EXPERIMENT_ID_FIELD_NUMBER: _ClassVar[int]
- GATEWAY_ID_FIELD_NUMBER: _ClassVar[int]
- experiment_id: str
- gateway_id: str
- def __init__(self, experiment_id: _Optional[str] = ..., gateway_id:
_Optional[str] = ...) -> None: ...
-
-class ProcessSubmitEvent(_message.Message):
- __slots__ = ("process_id", "gateway_id", "experiment_id", "token_id")
- PROCESS_ID_FIELD_NUMBER: _ClassVar[int]
- GATEWAY_ID_FIELD_NUMBER: _ClassVar[int]
- EXPERIMENT_ID_FIELD_NUMBER: _ClassVar[int]
- TOKEN_ID_FIELD_NUMBER: _ClassVar[int]
- process_id: str
- gateway_id: str
- experiment_id: str
- token_id: str
- def __init__(self, process_id: _Optional[str] = ..., gateway_id:
_Optional[str] = ..., experiment_id: _Optional[str] = ..., token_id:
_Optional[str] = ...) -> None: ...
-
-class ProcessTerminateEvent(_message.Message):
- __slots__ = ("process_id", "gateway_id", "token_id")
- PROCESS_ID_FIELD_NUMBER: _ClassVar[int]
- GATEWAY_ID_FIELD_NUMBER: _ClassVar[int]
- TOKEN_ID_FIELD_NUMBER: _ClassVar[int]
- process_id: str
- gateway_id: str
- token_id: str
- def __init__(self, process_id: _Optional[str] = ..., gateway_id:
_Optional[str] = ..., token_id: _Optional[str] = ...) -> None: ...
-
-class JobStatusChangeEvent(_message.Message):
- __slots__ = ("state", "job_identity")
- STATE_FIELD_NUMBER: _ClassVar[int]
- JOB_IDENTITY_FIELD_NUMBER: _ClassVar[int]
- state: _status_pb2.JobState
- job_identity: JobIdentifier
- def __init__(self, state: _Optional[_Union[_status_pb2.JobState, str]] =
..., job_identity: _Optional[_Union[JobIdentifier, _Mapping]] = ...) -> None:
...
-
-class JobStatusChangeRequestEvent(_message.Message):
- __slots__ = ("state", "job_identity")
- STATE_FIELD_NUMBER: _ClassVar[int]
- JOB_IDENTITY_FIELD_NUMBER: _ClassVar[int]
- state: _status_pb2.JobState
- job_identity: JobIdentifier
- def __init__(self, state: _Optional[_Union[_status_pb2.JobState, str]] =
..., job_identity: _Optional[_Union[JobIdentifier, _Mapping]] = ...) -> None:
...
-
-class ExperimentIntermediateOutputsEvent(_message.Message):
- __slots__ = ("experiment_id", "gateway_id", "output_names")
- EXPERIMENT_ID_FIELD_NUMBER: _ClassVar[int]
- GATEWAY_ID_FIELD_NUMBER: _ClassVar[int]
- OUTPUT_NAMES_FIELD_NUMBER: _ClassVar[int]
- experiment_id: str
- gateway_id: str
- output_names: _containers.RepeatedScalarFieldContainer[str]
- def __init__(self, experiment_id: _Optional[str] = ..., gateway_id:
_Optional[str] = ..., output_names: _Optional[_Iterable[str]] = ...) -> None:
...
-
-class Message(_message.Message):
- __slots__ = ("event", "message_id", "message_type", "updated_time",
"message_level")
- EVENT_FIELD_NUMBER: _ClassVar[int]
- MESSAGE_ID_FIELD_NUMBER: _ClassVar[int]
- MESSAGE_TYPE_FIELD_NUMBER: _ClassVar[int]
- UPDATED_TIME_FIELD_NUMBER: _ClassVar[int]
- MESSAGE_LEVEL_FIELD_NUMBER: _ClassVar[int]
- event: bytes
- message_id: str
- message_type: MessageType
- updated_time: int
- message_level: MessageLevel
- def __init__(self, event: _Optional[bytes] = ..., message_id:
_Optional[str] = ..., message_type: _Optional[_Union[MessageType, str]] = ...,
updated_time: _Optional[int] = ..., message_level:
_Optional[_Union[MessageLevel, str]] = ...) -> None: ...
diff --git
a/airavata-python-sdk/airavata_sdk/generated/org/apache/airavata/model/messaging/messaging_events_pb2_grpc.py
b/airavata-python-sdk/airavata_sdk/generated/org/apache/airavata/model/messaging/messaging_events_pb2_grpc.py
deleted file mode 100644
index 7e38cd29e2..0000000000
---
a/airavata-python-sdk/airavata_sdk/generated/org/apache/airavata/model/messaging/messaging_events_pb2_grpc.py
+++ /dev/null
@@ -1,24 +0,0 @@
-# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
-"""Client and server classes corresponding to protobuf-defined services."""
-import grpc
-import warnings
-
-
-GRPC_GENERATED_VERSION = '1.80.0'
-GRPC_VERSION = grpc.__version__
-_version_not_supported = False
-
-try:
- from grpc._utilities import first_version_is_lower
- _version_not_supported = first_version_is_lower(GRPC_VERSION,
GRPC_GENERATED_VERSION)
-except ImportError:
- _version_not_supported = True
-
-if _version_not_supported:
- raise RuntimeError(
- f'The grpc package installed is at version {GRPC_VERSION},'
- + ' but the generated code in
org/apache/airavata/model/messaging/messaging_events_pb2_grpc.py depends on'
- + f' grpcio>={GRPC_GENERATED_VERSION}.'
- + f' Please upgrade your grpc module to
grpcio>={GRPC_GENERATED_VERSION}'
- + f' or downgrade your generated code using
grpcio-tools<={GRPC_VERSION}.'
- )
