Skip to content

Commit cea27e5

Browse files
IgorChvyrov-smIgorChvyrov-sm
committed
Update linter rules for 100 symbols in line
1 parent 310e159 commit cea27e5

165 files changed

Lines changed: 1954 additions & 616 deletions

File tree

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

‎pyproject.toml‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,7 @@ pytest-asyncio = "^1.1.0"
5252

5353
[tool.ruff]
5454
target-version = "py39"
55-
line-length = 120
55+
line-length = 100
5656
src = ["src"]
5757
extend-exclude = [
5858
"tests/",

‎src/conductor/asyncio_client/adapters/api_client_adapter.py‎

Lines changed: 12 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -113,9 +113,12 @@ async def call_api(
113113
token_expired = (
114114
self.configuration.token_update_time > 0
115115
and time.time()
116-
>= self.configuration.token_update_time + self.configuration.auth_token_ttl_sec
116+
>= self.configuration.token_update_time
117+
+ self.configuration.auth_token_ttl_sec
118+
)
119+
invalid_token = not self.configuration._http_config.api_key.get(
120+
"api_key"
117121
)
118-
invalid_token = not self.configuration._http_config.api_key.get("api_key")
119122

120123
if invalid_token or token_expired:
121124
token = await self.refresh_authorization_token()
@@ -156,7 +159,8 @@ async def call_api(
156159
token_expired = (
157160
self.configuration.token_update_time > 0
158161
and time.time()
159-
>= self.configuration.token_update_time + self.configuration.auth_token_ttl_sec
162+
>= self.configuration.token_update_time
163+
+ self.configuration.auth_token_ttl_sec
160164
)
161165
invalid_token = not self.configuration._http_config.api_key.get("api_key")
162166

@@ -208,7 +212,11 @@ def response_deserialize(
208212
assert response_data.data is not None, msg
209213

210214
response_type = response_types_map.get(str(response_data.status), None)
211-
if not response_type and isinstance(response_data.status, int) and 100 <= response_data.status <= 599:
215+
if (
216+
not response_type
217+
and isinstance(response_data.status, int)
218+
and 100 <= response_data.status <= 599
219+
):
212220
# if not found, look for '1XX', '2XX', etc.
213221
response_type = response_types_map.get(str(response_data.status)[0] + "XX", None)
214222

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

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -25,11 +25,15 @@ def from_dict(cls, obj: Optional[Dict[str, Any]]) -> Optional[Self]:
2525
{
2626
"action": obj.get("action"),
2727
"complete_task": (
28-
TaskDetailsAdapter.from_dict(obj["complete_task"]) if obj.get("complete_task") is not None else None
28+
TaskDetailsAdapter.from_dict(obj["complete_task"])
29+
if obj.get("complete_task") is not None
30+
else None
2931
),
3032
"expandInlineJSON": obj.get("expandInlineJSON"),
3133
"fail_task": (
32-
TaskDetailsAdapter.from_dict(obj["fail_task"]) if obj.get("fail_task") is not None else None
34+
TaskDetailsAdapter.from_dict(obj["fail_task"])
35+
if obj.get("fail_task") is not None
36+
else None
3337
),
3438
"start_workflow": (
3539
StartWorkflowRequestAdapter.from_dict(obj["start_workflow"])

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

Lines changed: 11 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,9 @@
1111

1212
class AnyAdapter(Any):
1313
all_fields: Optional[Dict[str, AnyType]] = Field(default=None, alias="allFields")
14-
descriptor_for_type: Optional["DescriptorAdapter"] = Field(default=None, alias="descriptorForType")
14+
descriptor_for_type: Optional["DescriptorAdapter"] = Field(
15+
default=None, alias="descriptorForType"
16+
)
1517
unknown_fields: Optional["UnknownFieldSetAdapter"] = Field(default=None, alias="unknownFields")
1618

1719
@classmethod
@@ -43,14 +45,20 @@ def from_dict(cls, obj: Optional[Dict[str, Any]]) -> Optional[Self]:
4345
"serializedSize": obj.get("serializedSize"),
4446
"typeUrl": obj.get("typeUrl"),
4547
"typeUrlBytes": (
46-
ByteStringAdapter.from_dict(obj["typeUrlBytes"]) if obj.get("typeUrlBytes") is not None else None
48+
ByteStringAdapter.from_dict(obj["typeUrlBytes"])
49+
if obj.get("typeUrlBytes") is not None
50+
else None
4751
),
4852
"unknownFields": (
4953
UnknownFieldSetAdapter.from_dict(obj["unknownFields"])
5054
if obj.get("unknownFields") is not None
5155
else None
5256
),
53-
"value": (ByteStringAdapter.from_dict(obj["value"]) if obj.get("value") is not None else None),
57+
"value": (
58+
ByteStringAdapter.from_dict(obj["value"])
59+
if obj.get("value") is not None
60+
else None
61+
),
5462
}
5563
)
5664
return _obj

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

Lines changed: 10 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -23,8 +23,16 @@ def from_dict(cls, obj: Optional[Dict[str, Any]]) -> Optional[Self]:
2323
_obj = cls.model_validate(
2424
{
2525
"access": obj.get("access"),
26-
"subject": (SubjectRefAdapter.from_dict(obj["subject"]) if obj.get("subject") is not None else None),
27-
"target": (TargetRefAdapter.from_dict(obj["target"]) if obj.get("target") is not None else None),
26+
"subject": (
27+
SubjectRefAdapter.from_dict(obj["subject"])
28+
if obj.get("subject") is not None
29+
else None
30+
),
31+
"target": (
32+
TargetRefAdapter.from_dict(obj["target"])
33+
if obj.get("target") is not None
34+
else None
35+
),
2836
}
2937
)
3038
return _obj

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

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,9 @@ def from_dict(cls, obj: Optional[Dict[str, Any]]) -> Optional[Self]:
3434
"name": obj.get("name"),
3535
"orkesWorkersApp": obj.get("orkesWorkersApp"),
3636
"roles": (
37-
[RoleAdapter.from_dict(_item) for _item in obj["roles"]] if obj.get("roles") is not None else None
37+
[RoleAdapter.from_dict(_item) for _item in obj["roles"]]
38+
if obj.get("roles") is not None
39+
else None
3840
),
3941
"uuid": obj.get("uuid"),
4042
}

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

Lines changed: 12 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -10,8 +10,12 @@
1010

1111
class DeclarationAdapter(Declaration):
1212
all_fields: Optional[Dict[str, Dict[str, Any]]] = Field(default=None, alias="allFields")
13-
default_instance_for_type: Optional["DeclarationAdapter"] = Field(default=None, alias="defaultInstanceForType")
14-
descriptor_for_type: Optional["DescriptorAdapter"] = Field(default=None, alias="descriptorForType")
13+
default_instance_for_type: Optional["DeclarationAdapter"] = Field(
14+
default=None, alias="defaultInstanceForType"
15+
)
16+
descriptor_for_type: Optional["DescriptorAdapter"] = Field(
17+
default=None, alias="descriptorForType"
18+
)
1519
unknown_fields: Optional["UnknownFieldSetAdapter"] = Field(default=None, alias="unknownFields")
1620

1721
@classmethod
@@ -38,7 +42,9 @@ def from_dict(cls, obj: Optional[Dict[str, Any]]) -> Optional[Self]:
3842
),
3943
"fullName": obj.get("fullName"),
4044
"fullNameBytes": (
41-
ByteStringAdapter.from_dict(obj["fullNameBytes"]) if obj.get("fullNameBytes") is not None else None
45+
ByteStringAdapter.from_dict(obj["fullNameBytes"])
46+
if obj.get("fullNameBytes") is not None
47+
else None
4248
),
4349
"initializationErrorString": obj.get("initializationErrorString"),
4450
"initialized": obj.get("initialized"),
@@ -50,7 +56,9 @@ def from_dict(cls, obj: Optional[Dict[str, Any]]) -> Optional[Self]:
5056
"serializedSize": obj.get("serializedSize"),
5157
"type": obj.get("type"),
5258
"typeBytes": (
53-
ByteStringAdapter.from_dict(obj["typeBytes"]) if obj.get("typeBytes") is not None else None
59+
ByteStringAdapter.from_dict(obj["typeBytes"])
60+
if obj.get("typeBytes") is not None
61+
else None
5462
),
5563
"unknownFields": (
5664
UnknownFieldSetAdapter.from_dict(obj["unknownFields"])

‎src/conductor/asyncio_client/adapters/models/declaration_or_builder_adapter.py‎

Lines changed: 12 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -10,8 +10,12 @@
1010

1111
class DeclarationOrBuilderAdapter(DeclarationOrBuilder):
1212
all_fields: Optional[Dict[str, Dict[str, Any]]] = Field(default=None, alias="allFields")
13-
default_instance_for_type: Optional["MessageAdapter"] = Field(default=None, alias="defaultInstanceForType")
14-
descriptor_for_type: Optional["DescriptorAdapter"] = Field(default=None, alias="descriptorForType")
13+
default_instance_for_type: Optional["MessageAdapter"] = Field(
14+
default=None, alias="defaultInstanceForType"
15+
)
16+
descriptor_for_type: Optional["DescriptorAdapter"] = Field(
17+
default=None, alias="descriptorForType"
18+
)
1519
unknown_fields: Optional["UnknownFieldSetAdapter"] = Field(default=None, alias="unknownFields")
1620

1721
@classmethod
@@ -38,7 +42,9 @@ def from_dict(cls, obj: Optional[Dict[str, Any]]) -> Optional[Self]:
3842
),
3943
"fullName": obj.get("fullName"),
4044
"fullNameBytes": (
41-
ByteStringAdapter.from_dict(obj["fullNameBytes"]) if obj.get("fullNameBytes") is not None else None
45+
ByteStringAdapter.from_dict(obj["fullNameBytes"])
46+
if obj.get("fullNameBytes") is not None
47+
else None
4248
),
4349
"initializationErrorString": obj.get("initializationErrorString"),
4450
"initialized": obj.get("initialized"),
@@ -47,7 +53,9 @@ def from_dict(cls, obj: Optional[Dict[str, Any]]) -> Optional[Self]:
4753
"reserved": obj.get("reserved"),
4854
"type": obj.get("type"),
4955
"typeBytes": (
50-
ByteStringAdapter.from_dict(obj["typeBytes"]) if obj.get("typeBytes") is not None else None
56+
ByteStringAdapter.from_dict(obj["typeBytes"])
57+
if obj.get("typeBytes") is not None
58+
else None
5159
),
5260
"unknownFields": (
5361
UnknownFieldSetAdapter.from_dict(obj["unknownFields"])

‎src/conductor/asyncio_client/adapters/models/descriptor_adapter.py‎

Lines changed: 16 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,9 @@ def from_dict(cls, obj: Optional[Dict[str, Any]]) -> Optional[Self]:
3232
_obj = cls.model_validate(
3333
{
3434
"containingType": (
35-
Descriptor.from_dict(obj["containingType"]) if obj.get("containingType") is not None else None
35+
Descriptor.from_dict(obj["containingType"])
36+
if obj.get("containingType") is not None
37+
else None
3638
),
3739
"enumTypes": (
3840
[EnumDescriptorAdapter.from_dict(_item) for _item in obj["enumTypes"]]
@@ -50,7 +52,11 @@ def from_dict(cls, obj: Optional[Dict[str, Any]]) -> Optional[Self]:
5052
if obj.get("fields") is not None
5153
else None
5254
),
53-
"file": (FileDescriptorAdapter.from_dict(obj["file"]) if obj.get("file") is not None else None),
55+
"file": (
56+
FileDescriptorAdapter.from_dict(obj["file"])
57+
if obj.get("file") is not None
58+
else None
59+
),
5460
"fullName": obj.get("fullName"),
5561
"index": obj.get("index"),
5662
"name": obj.get("name"),
@@ -65,9 +71,15 @@ def from_dict(cls, obj: Optional[Dict[str, Any]]) -> Optional[Self]:
6571
else None
6672
),
6773
"options": (
68-
MessageOptionsAdapter.from_dict(obj["options"]) if obj.get("options") is not None else None
74+
MessageOptionsAdapter.from_dict(obj["options"])
75+
if obj.get("options") is not None
76+
else None
77+
),
78+
"proto": (
79+
DescriptorProtoAdapter.from_dict(obj["proto"])
80+
if obj.get("proto") is not None
81+
else None
6982
),
70-
"proto": (DescriptorProtoAdapter.from_dict(obj["proto"]) if obj.get("proto") is not None else None),
7183
"realOneofs": (
7284
[OneofDescriptorAdapter.from_dict(_item) for _item in obj["realOneofs"]]
7385
if obj.get("realOneofs") is not None

0 commit comments

Comments
 (0)