Skip to content

Commit

Permalink
Merge pull request #313 from golemfactory/mf/poll-output
Browse files Browse the repository at this point in the history
Poll computation output by default
  • Loading branch information
mfranciszkiewicz authored Apr 7, 2021
2 parents 233b783 + 4d75196 commit 66b7b48
Showing 1 changed file with 3 additions and 1 deletion.
4 changes: 3 additions & 1 deletion yapapi/executor/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -122,6 +122,7 @@ def __init__(
driver: Optional[str] = None,
network: Optional[str] = None,
event_consumer: Optional[Callable[[Event], None]] = None,
stream_output: bool = False,
):
"""Create a new executor.
Expand All @@ -139,13 +140,14 @@ def __init__(
only payment platforms with the specified network will be used
:param event_consumer: a callable that processes events related to the
computation; by default it is a function that logs all events
:param stream_output: stream computation output from providers
"""
logger.debug("Creating Executor instance; parameters: %s", locals())

self._subnet: Optional[str] = subnet_tag
self._driver = driver.lower() if driver else DEFAULT_DRIVER
self._network = network.lower() if network else DEFAULT_NETWORK
self._stream_output = True
self._stream_output = stream_output
if not strategy:
strategy = LeastExpensiveLinearPayuMS(
max_fixed_price=Decimal("1.0"),
Expand Down

0 comments on commit 66b7b48

Please sign in to comment.