Skip to content
GitLab
Projects
Groups
Snippets
/
Help
Help
Support
Community forum
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in
Toggle navigation
Menu
Open sidebar
workflow
pypushflow
Commits
2e725562
Commit
2e725562
authored
Apr 07, 2020
by
payno
Browse files
pep8 outData -> outData
parent
ea706d65
Changes
5
Hide whitespace changes
Inline
Side-by-side
pypushflow/PythonActor.py
View file @
2e725562
...
...
@@ -51,7 +51,7 @@ def trace_unhandled_exceptions(func):
@
functools
.
wraps
(
func
)
def
wrapped_func
(
*
args
,
**
kwargs
):
try
:
out
D
ata
=
func
(
*
args
,
**
kwargs
)
out
_d
ata
=
func
(
*
args
,
**
kwargs
)
except
Exception
as
e
:
errorMessage
=
'{0}'
.
format
(
e
)
logger
.
exception
(
errorMessage
)
...
...
@@ -61,7 +61,7 @@ def trace_unhandled_exceptions(func):
traceBack
=
traceBack
,
data
=
args
[
1
]
)
return
out
D
ata
return
out
_d
ata
return
wrapped_func
...
...
@@ -274,13 +274,13 @@ class PythonActor(AbstractActor):
self
.
error_handler
.
triggerOnError
(
inData
=
oldInData
)
else
:
# TODO: what can be inData ? a list ? namedtuple ?
out
D
ata
=
{}
out
_d
ata
=
{}
for
key
,
value
in
inData
.
items
():
if
key
in
self
.
in_data
:
if
self
.
in_data
[
key
]
!=
value
:
out
D
ata
[
key
]
=
value
out
_d
ata
[
key
]
=
value
else
:
out
D
ata
[
key
]
=
value
out
_d
ata
[
key
]
=
value
# self.uploadDataToMongo(actorData={
# 'stopTime': datetime.datetime.now(),
# 'status': 'finished',
...
...
pypushflow/StopActor.py
View file @
2e725562
...
...
@@ -38,7 +38,7 @@ class StopActor(object):
self
.
name
=
name
self
.
lock
=
multiprocessing
.
Lock
()
self
.
lock
.
acquire
()
self
.
out
D
ata
=
None
self
.
out
_d
ata
=
None
self
.
parent
=
parent
def
trigger
(
self
,
inData
):
...
...
@@ -48,7 +48,7 @@ class StopActor(object):
if
self
.
errorHandler
is
not
None
:
self
.
errorHandler
.
errorHandler
.
stopActor
.
trigger
(
inData
)
else
:
self
.
out
D
ata
=
inData
self
.
out
_d
ata
=
inData
self
.
lock
.
release
()
def
join
(
self
,
timeout
=
7200
):
...
...
pypushflow/test/test_Actors.py
View file @
2e725562
...
...
@@ -51,9 +51,9 @@ class TestPythonActor(unittest.TestCase):
actor
.
connect
(
stopActor
)
actor
.
trigger
(
inData
)
stopActor
.
join
(
timeout
=
5
)
out
D
ata
=
stopActor
.
out
D
ata
self
.
assertIsNotNone
(
out
D
ata
)
self
.
assertEqual
(
out
D
ata
[
'reply'
],
'Hello Ragnar!'
)
out
_d
ata
=
stopActor
.
out
_d
ata
self
.
assertIsNotNone
(
out
_d
ata
)
self
.
assertEqual
(
out
_d
ata
[
'reply'
],
'Hello Ragnar!'
)
def
test_ErrorHandler
(
self
):
script
=
'pypushflow.test.pythonErrorHandlerTest.py'
...
...
@@ -69,9 +69,9 @@ class TestPythonActor(unittest.TestCase):
errorHandler
.
connect
(
stopActor
)
actor
.
trigger
(
inData
)
stopActor
.
join
(
timeout
=
5
)
out
D
ata
=
stopActor
.
out
D
ata
self
.
assertIsNotNone
(
out
D
ata
)
self
.
assertTrue
(
'WorkflowException'
in
out
D
ata
)
out
_d
ata
=
stopActor
.
out
_d
ata
self
.
assertIsNotNone
(
out
_d
ata
)
self
.
assertTrue
(
'WorkflowException'
in
out
_d
ata
)
def
test_ForkAndJoinActors
(
self
):
start
=
StartActor
()
...
...
@@ -93,9 +93,9 @@ class TestPythonActor(unittest.TestCase):
inData
=
{
'a'
:
1
}
start
.
trigger
(
inData
)
stop
.
join
(
timeout
=
5
)
out
D
ata
=
stop
.
out
D
ata
self
.
assertIsNotNone
(
out
D
ata
)
logger
.
info
(
out
D
ata
)
out
_d
ata
=
stop
.
out
_d
ata
self
.
assertIsNotNone
(
out
_d
ata
)
logger
.
info
(
out
_d
ata
)
def
suite
():
...
...
pypushflow/test/test_Workflows.py
View file @
2e725562
...
...
@@ -51,30 +51,30 @@ class TestWorkflows(unittest.TestCase):
def
test_Workflow1
(
self
):
testWorkflow1
=
Workflow1
(
'Test workflow 1'
)
inData
=
{
'name'
:
'Jerry'
}
out
D
ata
=
testWorkflow1
.
run
(
inData
)
self
.
assertIsNotNone
(
out
D
ata
)
self
.
assertEqual
(
out
D
ata
[
'reply'
],
'Hello Jerry!'
)
out
_d
ata
=
testWorkflow1
.
run
(
inData
)
self
.
assertIsNotNone
(
out
_d
ata
)
self
.
assertEqual
(
out
_d
ata
[
'reply'
],
'Hello Jerry!'
)
def
test_Workflow2
(
self
):
testWorkflow2
=
Workflow2
(
'Test workflow 2'
)
inData
=
{
'name'
:
'Tom'
}
out
D
ata
=
testWorkflow2
.
run
(
inData
)
self
.
assertIsNotNone
(
out
D
ata
)
self
.
assertTrue
(
'WorkflowException'
in
out
D
ata
)
out
_d
ata
=
testWorkflow2
.
run
(
inData
)
self
.
assertIsNotNone
(
out
_d
ata
)
self
.
assertTrue
(
'WorkflowException'
in
out
_d
ata
)
def
test_Workflow3
(
self
):
testWorkflow3
=
Workflow3
(
'Test workflow 3'
)
inData
=
{
'name'
:
'Cat'
}
out
D
ata
=
testWorkflow3
.
run
(
inData
)
self
.
assertIsNotNone
(
out
D
ata
)
self
.
assertEqual
(
out
D
ata
[
'reply'
],
'Hello Cat!'
)
out
_d
ata
=
testWorkflow3
.
run
(
inData
)
self
.
assertIsNotNone
(
out
_d
ata
)
self
.
assertEqual
(
out
_d
ata
[
'reply'
],
'Hello Cat!'
)
def
test_Workflow4
(
self
):
testWorkflow4
=
Workflow2
(
'Test workflow 4'
)
inData
=
{
'name'
:
'Dog'
}
out
D
ata
=
testWorkflow4
.
run
(
inData
)
self
.
assertIsNotNone
(
out
D
ata
)
self
.
assertTrue
(
'WorkflowException'
in
out
D
ata
)
out
_d
ata
=
testWorkflow4
.
run
(
inData
)
self
.
assertIsNotNone
(
out
_d
ata
)
self
.
assertTrue
(
'WorkflowException'
in
out
_d
ata
)
def
suite
():
...
...
pypushflow/test/test_representation.py
View file @
2e725562
...
...
@@ -44,7 +44,7 @@ def exec_(scheme, input_=None):
assert
isinstance
(
scheme
,
ProcessableWorkflow
)
scheme
.
_start_actor
.
trigger
(
input_
)
scheme
.
_end_actor
.
join
()
return
scheme
.
_end_actor
.
out
D
ata
return
scheme
.
_end_actor
.
out
_d
ata
class
TestScheme
(
unittest
.
TestCase
):
...
...
Write
Preview
Supports
Markdown
0%
Try again
or
attach a new file
.
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment