forked from PanDAWMS/pilot3
-
Notifications
You must be signed in to change notification settings - Fork 2
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
1 parent
cfa9836
commit f328531
Showing
3 changed files
with
22 additions
and
3 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
|
@@ -20,6 +20,7 @@ | |
# - Wen Guan, [email protected], 2017-2018 | ||
# - Paul Nilsson, [email protected], 2021-2023 | ||
|
||
"""Executor module for event service payloads.""" | ||
|
||
import os | ||
import time | ||
|
@@ -33,20 +34,30 @@ | |
|
||
|
||
class Executor(generic.Executor): | ||
"""Executor class for event service payloads.""" | ||
|
||
def __init__(self, args, job, out, err, traces): | ||
super(Executor, self).__init__(args, job, out, err, traces) | ||
""" | ||
Set initial values. | ||
:param args: args object | ||
:param job: | ||
:param out: | ||
:param err: | ||
:param traces: | ||
""" | ||
super().__init__(args, job, out, err, traces) | ||
|
||
def run_payload(self, job, cmd, out, err): | ||
""" | ||
(add description) | ||
Run the payload for the given job. | ||
:param job: job object. | ||
:param cmd: (unused in ES mode) | ||
:param out: stdout file object. | ||
:param err: stderr file object. | ||
:return: | ||
""" | ||
|
||
self.pre_setup(job) | ||
|
||
# get the payload command from the user specific code | ||
|
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
|
@@ -20,6 +20,8 @@ | |
# - Wen Guan, [email protected], 2018 | ||
# - Paul Nilsson, [email protected], 2020-2023 | ||
|
||
"""Executor module for event service merge payloads.""" | ||
|
||
import os | ||
|
||
from pilot.control.payloads import generic | ||
|
@@ -30,6 +32,8 @@ | |
|
||
|
||
class Executor(generic.Executor): | ||
"""Executor class for event service merge payloads.""" | ||
|
||
def __init__(self, args, job, out, err, traces): | ||
super(Executor, self).__init__(args, job, out, err, traces) | ||
|
||
|
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
|
@@ -23,6 +23,8 @@ | |
# - Paul Nilsson, [email protected], 2017-2023 | ||
# - Wen Guan, [email protected], 2018 | ||
|
||
"""Executor module for generic payloads.""" | ||
|
||
import time | ||
import os | ||
import signal | ||
|
@@ -48,6 +50,8 @@ | |
|
||
|
||
class Executor(object): | ||
"""Executor class for generic payloads.""" | ||
|
||
def __init__(self, args, job, out, err, traces): | ||
self.__args = args | ||
self.__job = job | ||
|