Source code for subway.plugins.debug

"""
debug for plain submitter and checker
"""

from uuid import uuid4

from ..framework import PlainChk, PlainSub



[docs]class DebugChk(PlainChk):

[docs]    def __init__(self, params=None, is_next=False, **kwargs):
        self.is_next = is_next
        super().__init__(params=params, **kwargs)



[docs]    def check_checking(self, jobid):
        print("the output path to be checked is %s" % jobid)
        if self.is_next is True:
            return [(str(uuid4()), {"core": 2})]
        return []




[docs]class DebugSub(PlainSub):

[docs]    def submit_pending(self, inputpath):
        print("the input path to be submitted as job is %s" % inputpath)
        return