-
Notifications
You must be signed in to change notification settings - Fork 28
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Fetch task template in dynamic workflow task #254
Conversation
Signed-off-by: Hongxin Liang <[email protected]>
@@ -185,34 +184,38 @@ public TaskIdentifier fetchLatestTaskId(NamedEntityIdentifier taskId) { | |||
return fetchLatestResource( | |||
taskId, | |||
request -> stub.listTasks(request).getTasksList(), | |||
TaskOuterClass.Task::getId, |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This double-function doesn't seem to be necessary.
@@ -374,8 +375,10 @@ public static Map<WorkflowIdentifier, WorkflowTemplate> collectSubWorkflows( | |||
.collect(toUnmodifiableMap()); | |||
} | |||
|
|||
public static Map<TaskIdentifier, TaskTemplate> collectTasks( | |||
List<Node> rewrittenNodes, Map<TaskIdentifier, TaskTemplate> allTasks) { | |||
public static Map<TaskIdentifier, TaskTemplate> collectDynamicWorkflowTasks( |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Rename it to be more specific. This is not used by anything else.
@@ -138,33 +137,7 @@ public void shouldPropagateCreateTaskToStub() { | |||
.version(TASK_VERSION) | |||
.build(); | |||
|
|||
TypedInterface interface_ = |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Extracted to Fixtures
.
Signed-off-by: Hongxin Liang <[email protected]>
Signed-off-by: Hongxin Liang <[email protected]>
Signed-off-by: Hongxin Liang <[email protected]>
TL;DR
Fetch task template when encountering remote task in dynamic workflow.
Type
Are all requirements met?
Complete description
#248 is not sufficient because in order to build dynamic job, we need task template, so in this PR we fetch task template for remote workflow.
Tracking Issue
NA
Follow-up issue
NA