Fixed tests and ruff linter errors

Author: IgorChvyrov-sm

src/conductor/asyncio_client/adapters/__init__.py

@@ -1,3 +1,3 @@
-from conductor.asyncio_client.adapters.api_client_adapter import ApiClientAdapter as ApiClient, ApiClientAdapter
+from conductor.asyncio_client.adapters.api_client_adapter import ApiClientAdapter as ApiClient
 
 __all__ = ["ApiClient"]

src/conductor/asyncio_client/adapters/api/task_resource_api.py

@@ -63,7 +63,7 @@ async def update_task_sync(
                             in the spec for a single request.
         :type _host_index: int, optional
         :return: Returns the result object.
-        """  # noqa: E501
+        """
 
         _param = self._update_task_sync_serialize(
             workflow_id=workflow_id,
@@ -78,7 +78,7 @@ async def update_task_sync(
         )
 
         _response_types_map: Dict[str, Optional[str]] = {
-            '200': "Workflow",
+            "200": "Workflow",
         }
         response_data = await self.api_client.call_api(
             *_param,

src/conductor/asyncio_client/adapters/api/workflow_resource_api.py

@@ -53,7 +53,7 @@ async def update_workflow_state(
                             in the spec for a single request.
         :type _host_index: int, optional
         :return: Returns the result object.
-        """  # noqa: E501
+        """
 
         _param = self._update_workflow_state_serialize(
             workflow_id=workflow_id,

src/conductor/asyncio_client/adapters/api_client_adapter.py

@@ -40,7 +40,7 @@ async def call_api(
                 post_params=post_params,
                 _request_timeout=_request_timeout,
             )
-            if response_data.status == 401:
+            if response_data.status == 401:  # noqa: PLR2004 (Unauthorized status code)
                 token = await self.refresh_authorization_token()
                 header_params["X-Authorization"] = token
                 response_data = await self.rest_client.request(
@@ -81,11 +81,9 @@ async def obtain_new_token(self):
     @classmethod
     def get_default(cls):
         """Return new instance of ApiClient.
-
         This method returns newly created, based on default constructor,
         object of ApiClient class or returns a copy of default
         ApiClient.
-
         :return: The ApiClient object.
         """
         if cls._default is None:

src/conductor/asyncio_client/adapters/models/__init__.py

@@ -447,6 +447,7 @@
     "EnumValueDescriptorProtoOrBuilder",
     "EnumValueOptions",
     "EnumValueOptions",
+    "EnumValueOptionsOrBuilder",
     "EnvironmentVariable",
     "EventHandler",
     "EventLog",
@@ -457,9 +458,11 @@
     "ExtendedWorkflowDef",
     "ExtensionRange",
     "ExtensionRangeOptions",
+    "ExtensionRangeOptionsOrBuilder",
     "ExtensionRangeOrBuilder",
     "FeatureSet",
     "FeatureSet",
+    "FeatureSetOrBuilder",
     "FieldDescriptor",
     "FieldDescriptorProto",
     "FieldDescriptorProtoOrBuilder",
@@ -525,6 +528,7 @@
     "SourceCodeInfoOrBuilder",
     "StartWorkflowRequest",
     "StateChangeEvent",
+    "SubWorkflowParams",
     "SubjectRef",
     "Tag",
     "TargetRef",
@@ -543,7 +547,7 @@
     "UpdateWorkflowVariables",
     "UpgradeWorkflowRequest",
     "UpsertGroupRequest",
-    "UpsertUserRequest",
+    "UpsertUserRequestAdapter",
     "WebhookConfig",
     "WebhookExecutionHistory",
     "Workflow",
@@ -557,9 +561,4 @@
     "WorkflowSummary",
     "WorkflowTask",
     "WorkflowTestRequest",
-    "EnumValueOptionsOrBuilder",
-    "ExtensionRangeOptionsOrBuilder",
-    "FeatureSetOrBuilder",
-    "SubWorkflowParams",
-    "UpsertUserRequestAdapter",
 ]

src/conductor/asyncio_client/adapters/models/action_adapter.py

@@ -57,16 +57,16 @@ def from_dict(cls, obj: Optional[Dict[str, Any]]) -> Optional[Self]:
         return _obj
 
 
-from conductor.asyncio_client.adapters.models.start_workflow_request_adapter import (
+from conductor.asyncio_client.adapters.models.start_workflow_request_adapter import (  # noqa: E402
     StartWorkflowRequestAdapter,
 )
-from conductor.asyncio_client.adapters.models.task_details_adapter import (
+from conductor.asyncio_client.adapters.models.task_details_adapter import (  # noqa: E402
     TaskDetailsAdapter,
 )
-from conductor.asyncio_client.adapters.models.terminate_workflow_adapter import (
+from conductor.asyncio_client.adapters.models.terminate_workflow_adapter import (  # noqa: E402
     TerminateWorkflowAdapter,
 )
-from conductor.asyncio_client.adapters.models.update_workflow_variables_adapter import (
+from conductor.asyncio_client.adapters.models.update_workflow_variables_adapter import (  # noqa: E402
     UpdateWorkflowVariablesAdapter,
 )
 

src/conductor/asyncio_client/adapters/models/any_adapter.py

@@ -66,13 +66,13 @@ def from_dict(cls, obj: Optional[Dict[str, Any]]) -> Optional[Self]:
         return _obj
 
 
-from conductor.asyncio_client.adapters.models.byte_string_adapter import (
+from conductor.asyncio_client.adapters.models.byte_string_adapter import (  # noqa: E402
     ByteStringAdapter,
 )
-from conductor.asyncio_client.adapters.models.descriptor_adapter import (
+from conductor.asyncio_client.adapters.models.descriptor_adapter import (  # noqa: E402
     DescriptorAdapter,
 )
-from conductor.asyncio_client.adapters.models.unknown_field_set_adapter import (
+from conductor.asyncio_client.adapters.models.unknown_field_set_adapter import (  # noqa: E402
     UnknownFieldSetAdapter,
 )
 

src/conductor/asyncio_client/adapters/models/authorization_request_adapter.py

@@ -38,10 +38,10 @@ def from_dict(cls, obj: Optional[Dict[str, Any]]) -> Optional[Self]:
         return _obj
 
 
-from conductor.asyncio_client.adapters.models.subject_ref_adapter import (
+from conductor.asyncio_client.adapters.models.subject_ref_adapter import (  # noqa: E402
     SubjectRefAdapter,
 )
-from conductor.asyncio_client.adapters.models.target_ref_adapter import (
+from conductor.asyncio_client.adapters.models.target_ref_adapter import (  # noqa: E402
     TargetRefAdapter,
 )
 

src/conductor/asyncio_client/adapters/models/conductor_user_adapter.py

@@ -44,7 +44,7 @@ def from_dict(cls, obj: Optional[Dict[str, Any]]) -> Optional[Self]:
         return _obj
 
 
-from conductor.asyncio_client.adapters.models.group_adapter import GroupAdapter
-from conductor.asyncio_client.adapters.models.role_adapter import RoleAdapter
+from conductor.asyncio_client.adapters.models.group_adapter import GroupAdapter  # noqa: E402
+from conductor.asyncio_client.adapters.models.role_adapter import RoleAdapter  # noqa: E402
 
 ConductorUserAdapter.model_rebuild(raise_errors=False)

src/conductor/asyncio_client/adapters/models/declaration_adapter.py

@@ -74,13 +74,13 @@ def from_dict(cls, obj: Optional[Dict[str, Any]]) -> Optional[Self]:
         return _obj
 
 
-from conductor.asyncio_client.adapters.models.byte_string_adapter import (
+from conductor.asyncio_client.adapters.models.byte_string_adapter import (  # noqa: E402
     ByteStringAdapter,
 )
-from conductor.asyncio_client.adapters.models.descriptor_adapter import (
+from conductor.asyncio_client.adapters.models.descriptor_adapter import (  # noqa: E402
     DescriptorAdapter,
 )
-from conductor.asyncio_client.adapters.models.unknown_field_set_adapter import (
+from conductor.asyncio_client.adapters.models.unknown_field_set_adapter import (  # noqa: E402
     UnknownFieldSetAdapter,
 )