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
Imène Lajili
clowdflows
Commits
94ac0f76
Commit
94ac0f76
authored
Mar 25, 2015
by
Janez K
Browse files
bugfixes
parent
157103d8
Changes
1
Hide whitespace changes
Inline
Side-by-side
workflows/engine.py
View file @
94ac0f76
...
...
@@ -2,6 +2,7 @@ import workflows.library
import
time
import
random
from
workflows.tasks
import
*
from
django.conf
import
settings
class
WidgetRunner
():
def
__init__
(
self
,
widget
,
workflow_runner
,
standalone
=
False
):
...
...
@@ -32,13 +33,13 @@ class WidgetRunner():
if
self
.
widget
.
abstract_widget
.
wsdl
!=
''
:
input_dict
[
'wsdl'
]
=
self
.
widget
.
abstract_widget
.
wsdl
input_dict
[
'wsdl_method'
]
=
self
.
widget
.
abstract_widget
.
wsdl_method
if
self
.
abstract_widget
.
windows_queue
and
settings
.
USE_WINDOWS_QUEUE
:
if
self
.
widget
.
abstract_widget
.
windows_queue
and
settings
.
USE_WINDOWS_QUEUE
:
if
self
.
widget
.
abstract_widget
.
has_progress_bar
:
outputs
=
executeWidgetFunction
.
apply_async
([
self
.
widget
,
input_dict
],
queue
=
"windows"
).
wait
()
elif
self
.
widget
.
abstract_widget
.
is_streaming
:
outputs
=
executeWidgetProgressBar
.
apply_async
([
self
.
widget
,
input_dict
],
queue
=
"windows"
).
wait
()
el
se
:
el
if
self
.
widget
.
abstract_widget
.
is_streaming
:
outputs
=
executeWidgetStreaming
.
apply_async
([
self
.
widget
,
input_dict
],
queue
=
"windows"
).
wait
()
else
:
outputs
=
executeWidgetFunction
.
apply_async
([
self
.
widget
,
input_dict
],
queue
=
"windows"
).
wait
()
else
:
if
self
.
widget
.
abstract_widget
.
has_progress_bar
:
outputs
=
function_to_call
(
input_dict
,
self
.
widget
)
...
...
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