Skip to content

Commit 2f4196e

Browse files
authored
Fix duplicated logging, only initialize defaultStreamHandler once. (#659)
1 parent 93c8c49 commit 2f4196e

File tree

4 files changed

+14
-21
lines changed

4 files changed

+14
-21
lines changed

cwltool/argparser.py

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -7,18 +7,14 @@
77

88
from typing import (Any, AnyStr, Dict, List, Sequence, Text, Union, cast)
99

10+
from . import loghandler
1011
from schema_salad.ref_resolver import file_uri
1112
from .process import (Process, shortname)
1213
from .resolver import ga4gh_tool_registries
1314
from .software_requirements import (SOFTWARE_REQUIREMENTS_ENABLED)
1415

1516
_logger = logging.getLogger("cwltool")
1617

17-
defaultStreamHandler = logging.StreamHandler()
18-
_logger.addHandler(defaultStreamHandler)
19-
_logger.setLevel(logging.INFO)
20-
21-
2218
def arg_parser(): # type: () -> argparse.ArgumentParser
2319
parser = argparse.ArgumentParser(description='Reference executor for Common Workflow Language')
2420
parser.add_argument("--basedir", type=Text)

cwltool/executors.py

Lines changed: 6 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -7,20 +7,15 @@
77

88
from typing import Dict, Text, Any, Tuple, Set, List
99

10-
from cwltool.builder import Builder
11-
from cwltool.errors import WorkflowException
12-
from cwltool.mutation import MutationManager
13-
from cwltool.job import JobBase
14-
from cwltool.process import relocateOutputs, cleanIntermediate, Process
15-
10+
from .builder import Builder
11+
from .errors import WorkflowException
12+
from .mutation import MutationManager
13+
from .job import JobBase
14+
from .process import relocateOutputs, cleanIntermediate, Process
15+
from . import loghandler
1616

1717
_logger = logging.getLogger("cwltool")
1818

19-
defaultStreamHandler = logging.StreamHandler()
20-
_logger.addHandler(defaultStreamHandler)
21-
_logger.setLevel(logging.INFO)
22-
23-
2419
class JobExecutor(object):
2520
__metaclass__ = ABCMeta
2621

cwltool/loghandler.py

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,6 @@
1+
import logging
2+
3+
_logger = logging.getLogger("cwltool")
4+
defaultStreamHandler = logging.StreamHandler()
5+
_logger.addHandler(defaultStreamHandler)
6+
_logger.setLevel(logging.INFO)

cwltool/main.py

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -28,6 +28,7 @@
2828
from .load_tool import (FetcherConstructorType, resolve_tool_uri,
2929
fetch_document, make_tool, validate_document, jobloaderctx,
3030
resolve_overrides, load_overrides)
31+
from .loghandler import defaultStreamHandler
3132
from .mutation import MutationManager
3233
from .pack import pack
3334
from .pathmapper import (adjustDirObjs, trim_listing, visit_class)
@@ -43,11 +44,6 @@
4344

4445
_logger = logging.getLogger("cwltool")
4546

46-
defaultStreamHandler = logging.StreamHandler()
47-
_logger.addHandler(defaultStreamHandler)
48-
_logger.setLevel(logging.INFO)
49-
50-
5147
def single_job_executor(t, # type: Process
5248
job_order_object, # type: Dict[Text, Any]
5349
**kwargs # type: Any

0 commit comments

Comments
 (0)