Skip to content

Commit 4ef2373

Browse files
committed
Add workflow run and jobs endpoints
1 parent b79b917 commit 4ef2373

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

jupyter_scheduler/extension.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,7 @@
2121

2222
JOB_DEFINITION_ID_REGEX = r"(?P<job_definition_id>\w+(?:-\w+)+)"
2323
JOB_ID_REGEX = r"(?P<job_id>\w+(?:-\w+)+)"
24+
WORKFLOW_ID_REGEX = r"(?P<workflow_id>\w+(?:-\w+)+)"
2425

2526

2627
class SchedulerApp(ExtensionApp):
@@ -37,6 +38,9 @@ class SchedulerApp(ExtensionApp):
3738
(r"scheduler/runtime_environments", RuntimeEnvironmentsHandler),
3839
(r"scheduler/config", ConfigHandler),
3940
(r"scheduler/worklows", WorkflowHandler),
41+
(r"scheduler/worklows/%s/run" % (WORKFLOW_ID_REGEX, JOB_ID_REGEX), WorkflowHandler),
42+
(r"scheduler/worklows/%s/jobs" % WORKFLOW_ID_REGEX, WorkflowHandler),
43+
(r"scheduler/worklows/%s/jobs/%s" % (WORKFLOW_ID_REGEX, JOB_ID_REGEX), WorkflowHandler),
4044
]
4145

4246
drop_tables = Bool(False, config=True, help="Drop the database tables before starting.")

0 commit comments

Comments
 (0)