Flush guarded output immediatly and remove parallelism for sharc jobs :(.
This commit is contained in:
parent
0a4e8839a1
commit
35ec26e001
|
@ -45,12 +45,14 @@ def help():
|
|||
def guarded_stdout(string):
|
||||
lock.acquire()
|
||||
sys.stdout.write(string)
|
||||
sys.stdout.flush()
|
||||
lock.release()
|
||||
|
||||
|
||||
def guarded_stderr(string):
|
||||
lock.acquire()
|
||||
sys.stderr.write(string)
|
||||
sys.stderr.flush()
|
||||
lock.release()
|
||||
|
||||
|
||||
|
|
|
@ -10,4 +10,4 @@ set -o nounset
|
|||
|
||||
printenv
|
||||
|
||||
"$BASEDIR/ExtensionCrawler/create-db" -a "$ARCHIVE" -n $SGE_TASK_ID -N $MAX_SGE_TASK_ID "$BASEDIR/out"
|
||||
"$BASEDIR/ExtensionCrawler/create-db" -t 1 -a "$ARCHIVE" -n $SGE_TASK_ID -N $MAX_SGE_TASK_ID "$BASEDIR/out"
|
||||
|
|
Loading…
Reference in New Issue