File tree 4 files changed +7
-2
lines changed
tests/UnitTests/TaskManager.Argo.Tests 4 files changed +7
-2
lines changed Original file line number Diff line number Diff line change @@ -74,5 +74,8 @@ public class ArgoPluginArguments
74
74
75
75
[ ConfigurationKeyName ( "messageSenderContainerMemoryLimit" ) ]
76
76
public string MessageSenderContainerMemoryLimit { get ; set ; } = "500Mi" ;
77
+
78
+ [ ConfigurationKeyName ( "taskPriorityClass" ) ]
79
+ public string TaskPriorityClass { get ; set ; } = string . Empty ;
77
80
}
78
81
}
Original file line number Diff line number Diff line change @@ -432,7 +432,7 @@ private async Task<Workflow> BuildWorkflowWrapper(CancellationToken cancellation
432
432
private void ProcessTaskPluginArguments ( Workflow workflow )
433
433
{
434
434
Guard . Against . Null ( workflow , nameof ( workflow ) ) ;
435
- var priorityClassName = Event . GetTaskPluginArgumentsParameter ( ArgoParameters . TaskPriorityClassName ) ?? "standard" ;
435
+ var priorityClassName = Event . GetTaskPluginArgumentsParameter ( ArgoParameters . TaskPriorityClassName ) ?? _options . Value . TaskManager . ArgoPluginArguments . TaskPriorityClass ;
436
436
437
437
foreach ( var template in workflow . Spec . Templates )
438
438
{
Original file line number Diff line number Diff line change 59
59
"messageGeneratorContainerCpuLimit" : " 1" ,
60
60
"messageGeneratorContainerMemoryLimit" : " 500Mi" ,
61
61
"messageSenderContainerCpuLimit" : " 1" ,
62
- "messageSenderContainerMemoryLimit" : " 500Mi"
62
+ "messageSenderContainerMemoryLimit" : " 500Mi" ,
63
+ "taskPriorityClass" : " "
63
64
},
64
65
"argoExitHookSendMessageContainerImage" : " ghcr.io/project-monai/monai-deploy-task-manager-callback:0.2.0-beta.211"
65
66
},
Original file line number Diff line number Diff line change @@ -100,6 +100,7 @@ public ArgoPluginTestBase()
100
100
Options . Value . TaskManager . ArgoPluginArguments . MessageGeneratorContainerMemoryLimit = MessageGeneratorContainerMemoryLimit ;
101
101
Options . Value . TaskManager . ArgoPluginArguments . MessageSenderContainerCpuLimit = MessageSenderContainerCpuLimit ;
102
102
Options . Value . TaskManager . ArgoPluginArguments . MessageSenderContainerMemoryLimit = MessageSenderContainerMemoryLimit ;
103
+ Options . Value . TaskManager . ArgoPluginArguments . TaskPriorityClass = "standard" ;
103
104
}
104
105
}
105
106
}
You can’t perform that action at this time.
0 commit comments