|
seq
1.1.0
|
|
seq
1.1.0
|
Retry loop task. More...
Public Member Functions | |
| def | __attrs_post_init__ |
| def | run |
| def | handle_exception |
| def | __attrs_post_init__ |
| def | run |
| def | handle_exception |
 Public Member Functions inherited from seqlib.seqtask.SeqTask | |
| def | __attrs_post_init__ |
| Inputs as dictionary, key by id. More... | |
| def | input_task_list |
| Get input tasks that are not finished. More... | |
| def | get_nodes |
| Get nodes from list od ids. More... | |
| def | run |
| def | get_task |
| Get my task object. More... | |
| def | abort |
| Aborts the asyncio task. More... | |
| def | reset |
| Creates a new task. More... | |
| def | resume_context |
| context to make sure the resume flag is set to False at the end More... | |
| def | __attrs_post_init__ |
| Inputs as dictionary, key by id. More... | |
| def | input_task_list |
| Get input tasks that are not finished. More... | |
| def | get_nodes |
| Get nodes from list od ids. More... | |
| def | run |
| def | get_task |
| Get my task object. More... | |
| def | abort |
| Aborts the asyncio task. More... | |
| def | reset |
| Creates a new task. More... | |
| def | resume_context |
| context to make sure the resume flag is set to False at the end More... | |
Public Attributes | |
| condition | |
| block | |
| err_tbl | |
| Public Attributes inherited from seqlib.seqtask.SeqTask | |
| resume | |
Static Public Attributes | |
| tuple | block = attr.ib(init=False) |
| tuple | err_tbl = attr.ib(init=False) |
| tuple | condition = attr.ib(init=False) |
| Static Public Attributes inherited from seqlib.seqtask.SeqTask | |
| tuple | id = attr.ib() |
| tuple | node = attr.ib(repr=False) |
| tuple | inputs = attr.ib(default=attr.Factory(list), repr=False) |
| tuple | resume = attr.ib(default=False, repr=False) |
Retry loop task.
| def seqlib.seqtask.RTask.__attrs_post_init__ | ( | self | ) |
| def seqlib.seqtask.RTask.__attrs_post_init__ | ( | self | ) |
| def seqlib.seqtask.RTask.handle_exception | ( | self | ) |
Exception handler
| def seqlib.seqtask.RTask.handle_exception | ( | self | ) |
Exception handler
| def seqlib.seqtask.RTask.run | ( | self | ) |
| def seqlib.seqtask.RTask.run | ( | self | ) |
|
static |
| seqlib.seqtask.RTask.block |
|
static |
| seqlib.seqtask.RTask.condition |
|
static |
| seqlib.seqtask.RTask.err_tbl |
1.8.5
