1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
|
"""Parsl is a Parallel Scripting Library, designed to enable efficient workflow execution.
Importing
---------
To get all the required functionality, we suggest importing the library as follows:
>>> import parsl
>>> from parsl import *
Constants
---------
AUTO_LOGNAME
Special value that indicates Parsl should construct a filename for logging.
"""
import logging
import multiprocessing as _multiprocessing
import os
import platform
from parsl.app.app import bash_app, join_app, python_app
from parsl.config import Config
from parsl.data_provider.files import File
from parsl.dataflow.dflow import DataFlowKernel, DataFlowKernelLoader
from parsl.executors import (
HighThroughputExecutor,
ThreadPoolExecutor,
WorkQueueExecutor,
)
from parsl.log_utils import set_file_logger, set_stream_logger
from parsl.monitoring import MonitoringHub
from parsl.version import VERSION
if platform.system() == 'Darwin':
_multiprocessing.set_start_method('fork', force=True)
__author__ = 'The Parsl Team'
__version__ = VERSION
AUTO_LOGNAME = -1
__all__ = [
# decorators
'bash_app',
'python_app',
'join_app',
# core
'Config',
'DataFlowKernel',
'File',
# logging
'set_stream_logger',
'set_file_logger',
'AUTO_LOGNAME',
# executors
'ThreadPoolExecutor',
'HighThroughputExecutor',
'WorkQueueExecutor',
'RadicalPilotExecutor',
# monitoring
'MonitoringHub',
]
clear = DataFlowKernelLoader.clear
load = DataFlowKernelLoader.load
dfk = DataFlowKernelLoader.dfk
wait_for_current_tasks = DataFlowKernelLoader.wait_for_current_tasks
logging.getLogger('parsl').addHandler(logging.NullHandler())
if platform.system() == 'Darwin':
os.environ['OBJC_DISABLE_INITIALIZE_FORK_SAFETY'] = 'YES'
|
