Skip to content

Commit 128c9ac

Browse files
antmendozaantmendoza
committed
typing
Signed-off-by: Antonio Mendoza Pérez <antmendoza@gmail.com>
1 parent bd879c7 commit 128c9ac

File tree

81 files changed

+1578
-1267
lines changed

Some content is hidden

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

81 files changed

+1578
-1267
lines changed

‎serverlessworkflow/sdk/action.py

Lines changed: 31 additions & 22 deletions
Original file line numberDiff line numberDiff line change
@@ -1,28 +1,37 @@
1+
from typing import Union
2+
3+
from serverlessworkflow.sdk.action_data_filter import ActionDataFilter
4+
from serverlessworkflow.sdk.event_ref import EventRef
5+
from serverlessworkflow.sdk.function_ref import FunctionRef
6+
from serverlessworkflow.sdk.sleep import Sleep
7+
from serverlessworkflow.sdk.sub_flow_ref import SubFlowRef
8+
9+
110
class Action:
2-
id = None
3-
name = None
4-
functionRef = None
5-
eventRef = None
6-
subFlowRef = None
7-
sleep = None
8-
retryRef = None
9-
nonRetryableErrors = None
10-
retryableErrors = None
11-
actionDataFilter = None
12-
condition = None
11+
id: str = None
12+
name: str = None
13+
functionRef: Union[str, FunctionRef] = None
14+
eventRef: EventRef = None
15+
subFlowRef: Union[str, SubFlowRef] = None
16+
sleep: Sleep = None
17+
retryRef: str = None
18+
nonRetryableErrors: [str] = None
19+
retryableErrors: [str] = None
20+
actionDataFilter: ActionDataFilter = None
21+
condition: str = None
1322

1423
def __init__(self,
15-
id=None,
16-
name=None,
17-
functionRef=None,
18-
eventRef=None,
19-
subFlowRef=None,
20-
sleep=None,
21-
retryRef=None,
22-
nonRetryableErrors=None,
23-
retryableErrors=None,
24-
actionDataFilter=None,
25-
condition=None,
24+
id: str = None,
25+
name: str = None,
26+
functionRef: Union[str, FunctionRef] = None,
27+
eventRef: EventRef = None,
28+
subFlowRef: Union[str, SubFlowRef] = None,
29+
sleep: Sleep = None,
30+
retryRef: str = None,
31+
nonRetryableErrors: [str] = None,
32+
retryableErrors: [str] = None,
33+
actionDataFilter: ActionDataFilter = None,
34+
condition: str = None,
2635
**kwargs):
2736

2837
# duplicated

‎serverlessworkflow/sdk/action_data_filter.py

Lines changed: 34 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,34 @@
1+
class ActionDataFilter:
2+
fromStateData: str = None
3+
useResults: bool = None
4+
results: str = None
5+
toStateData: str = None
6+
7+
def __init__(self,
8+
fromStateData: str = None,
9+
useResults: bool = None,
10+
results: str = None,
11+
toStateData: str = None,
12+
**kwargs):
13+
14+
# duplicated
15+
for local in list(locals()):
16+
if local in ["self", "kwargs"]:
17+
continue
18+
value = locals().get(local)
19+
if not value:
20+
continue
21+
if value == "true":
22+
value = True
23+
# duplicated
24+
25+
self.__setattr__(local.replace("_", ""), value)
26+
27+
# duplicated
28+
for k in kwargs.keys():
29+
value = kwargs[k]
30+
if value == "true":
31+
value = True
32+
33+
self.__setattr__(k.replace("_", ""), value)
34+
# duplicated

‎serverlessworkflow/sdk/eventdatafilter.py renamed to ‎serverlessworkflow/sdk/auth_def.py

Lines changed: 21 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -1,12 +1,26 @@
1-
class Eventdatafilter:
2-
useData = None
3-
data = None
4-
toStateData = None
1+
from enum import Enum
2+
from typing import Union
3+
4+
from serverlessworkflow.sdk.basic_props_def import BasicPropsDef
5+
from serverlessworkflow.sdk.bearer_props_def import BearerPropsDef
6+
from serverlessworkflow.sdk.oauth2props_def import Oauth2PropsDef
7+
8+
9+
class Scheme(Enum):
10+
BASIC = "basic"
11+
BEARER = "bearer"
12+
OAUTH2 = "oauth2"
13+
14+
15+
class AuthDef:
16+
name: str = None
17+
scheme: Scheme = None
18+
properties: Union[str, Union[BasicPropsDef, BearerPropsDef, Oauth2PropsDef]] = None
519

620
def __init__(self,
7-
useData=None,
8-
data=None,
9-
toStateData=None,
21+
name: str = None,
22+
scheme: Scheme = None,
23+
properties: Union[str, Union[BasicPropsDef, BearerPropsDef, Oauth2PropsDef]] = None,
1024
**kwargs):
1125

1226
# duplicated

‎serverlessworkflow/sdk/basic_props_def.py

Lines changed: 35 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,35 @@
1+
from serverlessworkflow.sdk.metadata import Metadata
2+
3+
4+
class BasicPropsDef:
5+
username: str = None
6+
password: str = None
7+
metadata: Metadata = None
8+
9+
def __init__(self,
10+
username: str = None,
11+
password: str = None,
12+
metadata: Metadata = None,
13+
**kwargs):
14+
15+
# duplicated
16+
for local in list(locals()):
17+
if local in ["self", "kwargs"]:
18+
continue
19+
value = locals().get(local)
20+
if not value:
21+
continue
22+
if value == "true":
23+
value = True
24+
# duplicated
25+
26+
self.__setattr__(local.replace("_", ""), value)
27+
28+
# duplicated
29+
for k in kwargs.keys():
30+
value = kwargs[k]
31+
if value == "true":
32+
value = True
33+
34+
self.__setattr__(k.replace("_", ""), value)
35+
# duplicated

‎serverlessworkflow/sdk/basicpropsdef.py renamed to ‎serverlessworkflow/sdk/bearer_props_def.py

Lines changed: 8 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -1,12 +1,13 @@
1-
class Basicpropsdef:
2-
username = None
3-
password = None
4-
metadata = None
1+
from serverlessworkflow.sdk.metadata import Metadata
2+
3+
4+
class BearerPropsDef:
5+
token: str = None
6+
metadata: Metadata = None
57

68
def __init__(self,
7-
username=None,
8-
password=None,
9-
metadata=None,
9+
token: str = None,
10+
metadata: Metadata = None,
1011
**kwargs):
1112

1213
# duplicated

‎serverlessworkflow/sdk/branch .py renamed to ‎serverlessworkflow/sdk/branch.py

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -1,16 +1,16 @@
1+
from serverlessworkflow.sdk.action import Action
2+
from serverlessworkflow.sdk.branch_timeout import BranchTimeOut
3+
4+
15
class Branch:
2-
name = None
3-
timeouts = None
4-
actionExecTimeout = None
5-
branchExecTimeout = None
6-
actions = None
6+
name: str = None
7+
timeouts: BranchTimeOut = None
8+
actions: [Action] = None
79

810
def __init__(self,
9-
name=None,
10-
timeouts=None,
11-
actionExecTimeout=None,
12-
branchExecTimeout=None,
13-
actions=None,
11+
name: str = None,
12+
timeouts: BranchTimeOut = None,
13+
actions: [Action] = None,
1414
**kwargs):
1515

1616
# duplicated

‎serverlessworkflow/sdk/branch_timeout.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,3 @@
1+
class BranchTimeOut:
2+
actionExecTimeOut: str = None # ActionExecTimeOut
3+
branchExecTimeOut: str = None # BranchExecTimeOut

‎serverlessworkflow/sdk/callback_state.py

Lines changed: 66 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,66 @@
1+
from typing import Union
2+
3+
from serverlessworkflow.sdk.action import Action
4+
from serverlessworkflow.sdk.callback_state_timeout import CallbackStateTimeOut
5+
from serverlessworkflow.sdk.end import End
6+
from serverlessworkflow.sdk.error import Error
7+
from serverlessworkflow.sdk.event_data_filter import EventDataFilter
8+
from serverlessworkflow.sdk.metadata import Metadata
9+
from serverlessworkflow.sdk.state_data_filter import StateDataFilter
10+
from serverlessworkflow.sdk.transition import Transition
11+
12+
13+
class CallbackState:
14+
id: str = None
15+
name: str = None
16+
type: 'callback' = None
17+
action: Action = None
18+
eventRef: str = None
19+
timeouts: CallbackStateTimeOut = None
20+
eventDataFilter: EventDataFilter = None
21+
stateDataFilter: StateDataFilter = None
22+
onErrors: [Error] = None
23+
transition: Union[str, Transition] = None
24+
end: Union[bool, End] = None
25+
compensatedBy: str = None
26+
usedForCompensation: bool = None
27+
metadata: Metadata = None
28+
29+
def __init__(self,
30+
id: str = None,
31+
name: str = None,
32+
type: 'callback' = None,
33+
action: Action = None,
34+
eventRef: str = None,
35+
timeouts: CallbackStateTimeOut = None,
36+
eventDataFilter: EventDataFilter = None,
37+
stateDataFilter: StateDataFilter = None,
38+
onErrors: [Error] = None,
39+
transition: Union[str, Transition] = None,
40+
end: Union[bool, End] = None,
41+
compensatedBy: str = None,
42+
usedForCompensation: bool = None,
43+
metadata: Metadata = None,
44+
**kwargs):
45+
# duplicated
46+
for local in list(locals()):
47+
if local in ["self", "kwargs"]:
48+
continue
49+
value = locals().get(local)
50+
if not value:
51+
continue
52+
if value == "true":
53+
value = True
54+
# duplicated
55+
56+
self.__setattr__(local.replace("_", ""), value)
57+
58+
# duplicated
59+
60+
for k in kwargs.keys():
61+
value = kwargs[k]
62+
if value == "true":
63+
value = True
64+
65+
self.__setattr__(k.replace("_", ""), value)
66+
# duplicated

‎serverlessworkflow/sdk/callback_state_timeout.py

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,7 @@
1+
from serverlessworkflow.sdk.state_exec_timeout import StateExecTimeOut
2+
3+
4+
class CallbackStateTimeOut:
5+
stateExecTimeOut: StateExecTimeOut = None
6+
actionExecTimeOut: str = None # ActionExecTimeOut
7+
eventTimeOut: str = None # EventTimeOut

‎serverlessworkflow/sdk/callbackstate.py

Lines changed: 0 additions & 60 deletions
This file was deleted.

‎serverlessworkflow/sdk/continue_as_def.py

Lines changed: 39 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,39 @@
1+
from typing import Union, Dict
2+
3+
from serverlessworkflow.sdk.workflow_exec_timeout import WorkflowExecTimeOut
4+
5+
6+
class ContinueAsDef:
7+
workflowId: str = None
8+
version: str = None
9+
data: Union[str, Dict[str, Dict]] = None
10+
workflowExecTimeOut: WorkflowExecTimeOut = None
11+
12+
def __init__(self,
13+
workflowId: str = None,
14+
version: str = None,
15+
data: Union[str, Dict[str, Dict]] = None,
16+
workflowExecTimeOut: WorkflowExecTimeOut = None,
17+
**kwargs):
18+
19+
# duplicated
20+
for local in list(locals()):
21+
if local in ["self", "kwargs"]:
22+
continue
23+
value = locals().get(local)
24+
if not value:
25+
continue
26+
if value == "true":
27+
value = True
28+
# duplicated
29+
30+
self.__setattr__(local.replace("_", ""), value)
31+
32+
# duplicated
33+
for k in kwargs.keys():
34+
value = kwargs[k]
35+
if value == "true":
36+
value = True
37+
38+
self.__setattr__(k.replace("_", ""), value)
39+
# duplicated

0 commit comments

Comments
 (0)