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
ea706d65
Commit
ea706d65
authored
Apr 07, 2020
by
payno
Browse files
[clean] remove some print
parent
04e1e435
Changes
2
Hide whitespace changes
Inline
Side-by-side
pypushflow/PythonActor.py
View file @
ea706d65
...
...
@@ -128,7 +128,6 @@ class AsyncFactory:
logger
.
debug
(
'Before apply_async, func={0}, callback={1}, errorCallback={2}'
.
format
(
self
.
node
,
self
.
callback
,
self
.
errorCallback
))
logger
.
debug
(
'args={0}, kwargs={1}'
.
format
(
args
,
kwargs
))
print
(
'args are'
,
args
)
if
self
.
callback
is
None
:
self
.
pool
.
apply_async
(
_exec_node
,
args
,
kwargs
)
elif
self
.
errorCallback
is
None
:
...
...
@@ -210,7 +209,6 @@ class PythonActor(AbstractActor):
:param data: input data
"""
print
(
'--- A; In data is {} ---'
.
format
(
in_data
))
# cast data to dict if necessary
if
hasattr
(
in_data
,
'to_dict'
):
_in_data
=
in_data
.
to_dict
()
...
...
@@ -235,7 +233,6 @@ class PythonActor(AbstractActor):
self
.
async_factory
=
AsyncFactory
(
self
.
actor_wrapper
.
run
,
callback
=
self
.
triggerDownStreamActor
,
errorCallback
=
self
.
error_handler
)
print
(
'indata is'
,
in_data
)
self
.
async_factory
.
call
(
self
.
actor_wrapper
.
node
.
process_pt
,
in_data
,
self
.
actor_wrapper
.
node
.
properties
)
...
...
@@ -255,11 +252,8 @@ class PythonActor(AbstractActor):
self
.
error_handler
.
triggerOnError
(
inData
)
def
triggerDownStreamActor
(
self
,
inData
=
{}):
print
(
'--- B ---'
)
logger
.
debug
(
'In triggerDownStreamActor for {0}'
.
format
(
self
.
name
))
if
isinstance
(
inData
,
WorkflowException
):
print
(
'1'
)
logger
.
error
(
'Error from previous actor! Not running down stream actors {0}'
.
format
([
actor
.
name
for
actor
in
self
.
listDownStreamActor
]))
workflowException
=
inData
oldInData
=
workflowException
.
data
...
...
@@ -279,7 +273,6 @@ class PythonActor(AbstractActor):
logger
.
error
(
'Trigger on error on errorHandler "{0}"'
.
format
(
self
.
error_handler
.
name
))
self
.
error_handler
.
triggerOnError
(
inData
=
oldInData
)
else
:
print
(
'2'
)
# TODO: what can be inData ? a list ? namedtuple ?
outData
=
{}
for
key
,
value
in
inData
.
items
():
...
...
pypushflow/Workflow.py
View file @
ea706d65
...
...
@@ -68,7 +68,6 @@ class ProcessableWorkflow:
self
.
_actor_factory
=
{}
for
node
in
self
.
_representation
.
nodes
:
name
=
'-'
.
join
((
str
(
node
.
id
),
node
.
_process_pt
))
print
(
node
)
self
.
_actor_factory
[
node
]
=
ActorFactory
(
parent
=
None
,
name
=
name
,
node
=
node
,
...
...
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