Commit 8e1182b2 authored by Daniel Scheffler's avatar Daniel Scheffler
Browse files

Minor changes.

parent 68d65ad4
......@@ -16,7 +16,9 @@ from .version import __version__, __versionalias__ # noqa (E402 + F401)
__author__ = """Daniel Scheffler"""
__email__ = 'daniel.scheffler@gfz-potsdam.de'
__all__ = ['algorithms',
__all__ = ['__version__',
'__versionalias__',
'algorithms',
'io',
'misc',
'processing',
......
......@@ -238,7 +238,7 @@ class LessThanFilter(logging.Filter):
# non-zero return means we log this message
return True if record.levelno < self.max_level else False
from redis_lock import Lock
class LogRecordStreamHandler(socketserver.StreamRequestHandler):
"""Handle incoming logs"""
......
......@@ -461,8 +461,8 @@ class process_controller(object):
# RUN PREPROCESSING
from .pipeline import run_complete_preprocessing
from ..misc.logging import LogReceiver
#with LogReceiver() as lr:
# alive = lr.is_alive
# with LogReceiver() as lr:
# alive = lr.is_alive
GMS_objs = imap_unordered(run_complete_preprocessing, dataset_groups, flatten_output=True)
# separate results into successful and failed objects
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment