Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Cancel state #1758

Merged
merged 11 commits into from
Nov 21, 2019
Prev Previous commit
Next Next commit
Remove stale cancel method code
  • Loading branch information
cicdw committed Nov 20, 2019
commit 86ffb2bbd6a4972e524fb550e48d360d6bd0614e
16 changes: 0 additions & 16 deletions src/prefect/engine/executors/dask.py
Original file line number Diff line number Diff line change
Expand Up @@ -246,22 +246,6 @@ def map(self, fn: Callable, *args: Any) -> List[dask.delayed]:
results.append(self.submit(fn, *args_i))
return results

def cancel(self, futures: Any) -> Any:
"""
Cancels futures, if possible.

Args:
- futures (Any): iterable of futures to compute

Returns:
- Any: an iterable of resolved futures
"""
for fut in futures:
try:
fut.cancel(force=True)
except Exception:
pass

def wait(self, futures: Any) -> Any:
"""
Resolves a `dask.delayed` object to its values. Blocks until the computation is complete.
Expand Down