Skip to content
GitLab
Projects
Groups
Snippets
Help
Loading...
Help
Help
Support
Community forum
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in / Register
Toggle navigation
Open sidebar
pipelet
Pipelet
Commits
c1e8ecda
Commit
c1e8ecda
authored
Dec 22, 2010
by
Betoule Marc
Browse files
changing default log levels
parent
ccf31df3
Changes
1
Hide whitespace changes
Inline
Side-by-side
Showing
1 changed file
with
6 additions
and
6 deletions
+6
-6
pipelet/launchers.py
pipelet/launchers.py
+6
-6
No files found.
pipelet/launchers.py
View file @
c1e8ecda
...
...
@@ -71,7 +71,7 @@ def set_logger (pipe, log_level):
init_logger
(
'worker'
,
work_log_file
,
level
=
log_level
)
def
launch_interactive
(
pipe
,
log_level
=
logging
.
DEBUG
):
def
launch_interactive
(
pipe
,
log_level
=
logging
.
INFO
):
""" Launch a local worker in the interactive session.
This is debugger compliant, so that exception in the segment
...
...
@@ -103,7 +103,7 @@ def launch_interactive(pipe, log_level=logging.DEBUG):
def
launch_thread
(
pipe
,
n
,
log_level
=
logging
.
CRITICAL
):
def
launch_thread
(
pipe
,
n
,
log_level
=
logging
.
WARNING
):
""" Launch a bunch of local workers in separate threads.
This is SMP machine compliant. Exceptions araising in the
...
...
@@ -141,7 +141,7 @@ class SchedulerManager(BaseManager):
"""
pass
def
launch_process
(
pipe
,
n
,
address
=
(
''
,
50000
),
authkey
=
'secret'
,
log_level
=
logging
.
CRITICAL
):
def
launch_process
(
pipe
,
n
,
address
=
(
''
,
50000
),
authkey
=
'secret'
,
log_level
=
logging
.
WARNING
):
""" Launch a bunch of local workers in separate processes .
This is usefull (compared to launch_thread) when the GIL becomes
...
...
@@ -181,7 +181,7 @@ def _scp(file, dest):
""" Wrapper around the scp command."""
subprocess
.
Popen
([
'scp'
,
file
,
dest
]).
communicate
()[
0
]
def
launch_ssh
(
pipe
,
host_list
,
address
=
None
,
authkey
=
'secret'
,
log_level
=
logging
.
CRITICAL
):
def
launch_ssh
(
pipe
,
host_list
,
address
=
None
,
authkey
=
'secret'
,
log_level
=
logging
.
WARNING
):
""" Launch a bunch of distant workers through ssh.
This is used mainly for testing purposes. It can be usefull to
...
...
@@ -216,7 +216,7 @@ def launch_ssh(pipe, host_list, address=None, authkey='secret',log_level=logging
for
w
in
processlist
:
w
.
wait
()
def
launch_pbs
(
pipe
,
n
,
address
=
None
,
authkey
=
'secret'
,
job_name
=
"job_"
,
log_level
=
logging
.
CRITICAL
,
cpu_time
=
"2:00:00"
,
server
=
False
,
job_header
=
"""
def
launch_pbs
(
pipe
,
n
,
address
=
None
,
authkey
=
'secret'
,
job_name
=
"job_"
,
log_level
=
logging
.
WARNING
,
cpu_time
=
"2:00:00"
,
server
=
False
,
job_header
=
"""
#/bin/bash
echo $PYTHONPATH
"""
):
...
...
@@ -266,7 +266,7 @@ python -m pipelet.launchers -H %s -p %s -s %s
def
launch_ccali
(
pipe
,
n
,
address
=
(
'127.0.0.1'
,
5000
),
authkey
=
'secret'
,
job_dir
=
"/sps/snls13/users/betoule/bqs/scripts"
,
job_name
=
"job_"
,
log_dir
=
"/sps/snls13/users/betoule/bqs/logs"
,
cpu_time
=
1000
,
scratch
=
"512MB"
,
mem
=
"512MB"
,
plateform
=
'LINUX'
,
server
=
False
,
log_level
=
logging
.
DEBUG
,
buff
=
None
):
cpu_time
=
1000
,
scratch
=
"512MB"
,
mem
=
"512MB"
,
plateform
=
'LINUX'
,
server
=
False
,
log_level
=
logging
.
INFO
,
buff
=
None
):
"""submit a bunch of distant workers to the BQS system
at CCIN2P3.
"""
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
.
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment