Fix futures import
This commit is contained in:
@@ -6,12 +6,12 @@ import uuid
|
||||
import dcoscli
|
||||
import requests
|
||||
import rollbar
|
||||
from concurrent.futures import ThreadPoolExecutor
|
||||
from dcos import util
|
||||
from dcoscli.constants import (ROLLBAR_SERVER_POST_KEY,
|
||||
SEGMENT_IO_CLI_ERROR_EVENT,
|
||||
SEGMENT_IO_CLI_EVENT, SEGMENT_IO_WRITE_KEY_DEV,
|
||||
SEGMENT_IO_WRITE_KEY_PROD, SEGMENT_URL)
|
||||
from futures import ThreadPoolExecutor
|
||||
from requests.auth import HTTPBasicAuth
|
||||
|
||||
logger = util.get_logger(__name__)
|
||||
|
||||
@@ -11,7 +11,7 @@ Options:
|
||||
"""
|
||||
import dcoscli
|
||||
import docopt
|
||||
import futures
|
||||
from concurrent.futures import ThreadPoolExecutor
|
||||
from dcos import cmds, emitting, options, subcommand, util
|
||||
|
||||
emitter = emitting.FlatEmitter()
|
||||
@@ -60,7 +60,7 @@ def _help(show_info):
|
||||
logger.debug("DCOS Path: {!r}".format(directory))
|
||||
|
||||
paths = subcommand.list_paths(directory)
|
||||
with futures.ThreadPoolExecutor(max_workers=len(paths)) as executor:
|
||||
with ThreadPoolExecutor(max_workers=len(paths)) as executor:
|
||||
results = executor.map(subcommand.documentation, paths)
|
||||
commands_message = options.make_command_summary_string(sorted(results))
|
||||
|
||||
|
||||
Reference in New Issue
Block a user