Update SDK using contracts version 8e7762b775b53b63c946e97bbea33bafa84a83b1

Author: eolymp-bot

eolymp/tasks/execution_service_http.py

@@ -0,0 +1,16 @@
+# -*- coding: utf-8 -*-
+# Generated by the protocol buffer compiler. DO NOT EDIT!
+# See https://github.com/eolymp/contracts/tree/main/cmd/protoc-gen-python-esdk for more details.
+"""Generated protocol buffer code."""
+
+import urllib.parse
+from google.protobuf import symbol_database as _symbol_database
+
+_sym_db = _symbol_database.Default()
+
+
+class ExecutionServiceClient:
+    def __init__(self, transport, url="https://api.eolymp.com"):
+        self.transport = transport
+        self.url = url
+

eolymp/tasks/execution_service_pb2.py

@@ -0,0 +1,48 @@
+from google.protobuf import any_pb2 as _any_pb2
+from google.protobuf import descriptor as _descriptor
+from google.protobuf import message as _message
+from collections.abc import Mapping as _Mapping
+from typing import ClassVar as _ClassVar, Optional as _Optional, Union as _Union
+
+DESCRIPTOR: _descriptor.FileDescriptor
+
+class ExecuteTaskInput(_message.Message):
+    __slots__ = ("task_id", "task", "checkpoint", "attempt")
+    TASK_ID_FIELD_NUMBER: _ClassVar[int]
+    TASK_FIELD_NUMBER: _ClassVar[int]
+    CHECKPOINT_FIELD_NUMBER: _ClassVar[int]
+    ATTEMPT_FIELD_NUMBER: _ClassVar[int]
+    task_id: str
+    task: _any_pb2.Any
+    checkpoint: _any_pb2.Any
+    attempt: int
+    def __init__(self, task_id: _Optional[str] = ..., task: _Optional[_Union[_any_pb2.Any, _Mapping]] = ..., checkpoint: _Optional[_Union[_any_pb2.Any, _Mapping]] = ..., attempt: _Optional[int] = ...) -> None: ...
+
+class ExecuteTaskOutput(_message.Message):
+    __slots__ = ("progress", "checkpoint", "record")
+    class Progress(_message.Message):
+        __slots__ = ("progress", "total", "status_message")
+        PROGRESS_FIELD_NUMBER: _ClassVar[int]
+        TOTAL_FIELD_NUMBER: _ClassVar[int]
+        STATUS_MESSAGE_FIELD_NUMBER: _ClassVar[int]
+        progress: int
+        total: int
+        status_message: str
+        def __init__(self, progress: _Optional[int] = ..., total: _Optional[int] = ..., status_message: _Optional[str] = ...) -> None: ...
+    class Checkpoint(_message.Message):
+        __slots__ = ("checkpoint",)
+        CHECKPOINT_FIELD_NUMBER: _ClassVar[int]
+        checkpoint: _any_pb2.Any
+        def __init__(self, checkpoint: _Optional[_Union[_any_pb2.Any, _Mapping]] = ...) -> None: ...
+    class Record(_message.Message):
+        __slots__ = ("line",)
+        LINE_FIELD_NUMBER: _ClassVar[int]
+        line: str
+        def __init__(self, line: _Optional[str] = ...) -> None: ...
+    PROGRESS_FIELD_NUMBER: _ClassVar[int]
+    CHECKPOINT_FIELD_NUMBER: _ClassVar[int]
+    RECORD_FIELD_NUMBER: _ClassVar[int]
+    progress: ExecuteTaskOutput.Progress
+    checkpoint: ExecuteTaskOutput.Checkpoint
+    record: ExecuteTaskOutput.Record
+    def __init__(self, progress: _Optional[_Union[ExecuteTaskOutput.Progress, _Mapping]] = ..., checkpoint: _Optional[_Union[ExecuteTaskOutput.Checkpoint, _Mapping]] = ..., record: _Optional[_Union[ExecuteTaskOutput.Record, _Mapping]] = ...) -> None: ...

eolymp/tasks/execution_service_pb2.pyi

@@ -11,7 +11,7 @@ from typing import ClassVar as _ClassVar, Optional as _Optional, Union as _Union
 DESCRIPTOR: _descriptor.FileDescriptor
 
 class Task(_message.Message):
-    __slots__ = ("id", "type", "reference", "status", "payload", "progress", "total", "status_message", "error", "log_url", "attempt", "created_at", "started_at", "finished_at", "created_by")
+    __slots__ = ("id", "type", "resource", "status", "payload", "progress", "total", "status_message", "error", "log_url", "attempt", "created_at", "started_at", "finished_at", "created_by")
     class Status(int, metaclass=_enum_type_wrapper.EnumTypeWrapper):
         __slots__ = ()
         UNKNOWN: _ClassVar[Task.Status]
@@ -30,7 +30,7 @@ class Task(_message.Message):
     CANCELLED: Task.Status
     ID_FIELD_NUMBER: _ClassVar[int]
     TYPE_FIELD_NUMBER: _ClassVar[int]
-    REFERENCE_FIELD_NUMBER: _ClassVar[int]
+    RESOURCE_FIELD_NUMBER: _ClassVar[int]
     STATUS_FIELD_NUMBER: _ClassVar[int]
     PAYLOAD_FIELD_NUMBER: _ClassVar[int]
     PROGRESS_FIELD_NUMBER: _ClassVar[int]
@@ -45,7 +45,7 @@ class Task(_message.Message):
     CREATED_BY_FIELD_NUMBER: _ClassVar[int]
     id: str
     type: str
-    reference: str
+    resource: str
     status: Task.Status
     payload: _struct_pb2.Struct
     progress: int
@@ -58,4 +58,4 @@ class Task(_message.Message):
     started_at: _timestamp_pb2.Timestamp
     finished_at: _timestamp_pb2.Timestamp
     created_by: str
-    def __init__(self, id: _Optional[str] = ..., type: _Optional[str] = ..., reference: _Optional[str] = ..., status: _Optional[_Union[Task.Status, str]] = ..., payload: _Optional[_Union[_struct_pb2.Struct, _Mapping]] = ..., progress: _Optional[int] = ..., total: _Optional[int] = ..., status_message: _Optional[str] = ..., error: _Optional[str] = ..., log_url: _Optional[str] = ..., attempt: _Optional[int] = ..., created_at: _Optional[_Union[datetime.datetime, _timestamp_pb2.Timestamp, _Mapping]] = ..., started_at: _Optional[_Union[datetime.datetime, _timestamp_pb2.Timestamp, _Mapping]] = ..., finished_at: _Optional[_Union[datetime.datetime, _timestamp_pb2.Timestamp, _Mapping]] = ..., created_by: _Optional[str] = ...) -> None: ...
+    def __init__(self, id: _Optional[str] = ..., type: _Optional[str] = ..., resource: _Optional[str] = ..., status: _Optional[_Union[Task.Status, str]] = ..., payload: _Optional[_Union[_struct_pb2.Struct, _Mapping]] = ..., progress: _Optional[int] = ..., total: _Optional[int] = ..., status_message: _Optional[str] = ..., error: _Optional[str] = ..., log_url: _Optional[str] = ..., attempt: _Optional[int] = ..., created_at: _Optional[_Union[datetime.datetime, _timestamp_pb2.Timestamp, _Mapping]] = ..., started_at: _Optional[_Union[datetime.datetime, _timestamp_pb2.Timestamp, _Mapping]] = ..., finished_at: _Optional[_Union[datetime.datetime, _timestamp_pb2.Timestamp, _Mapping]] = ..., created_by: _Optional[str] = ...) -> None: ...