This is an automated email from the ASF dual-hosted git repository.

pbacsko pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/yunikorn-k8shim.git


The following commit(s) were added to refs/heads/master by this push:
     new 36111c41 [YUNIKORN-2654] Remove unused code in k8shim context
36111c41 is described below

commit 36111c41d97658e168e640c284fe8d71921883b4
Author: 0lai0 <[email protected]>
AuthorDate: Tue Jun 4 10:51:52 2024 +0200

    [YUNIKORN-2654] Remove unused code in k8shim context
    
    Closes: #854
    
    Signed-off-by: Peter Bacsko <[email protected]>
---
 pkg/cache/context.go | 23 -----------------------
 1 file changed, 23 deletions(-)

diff --git a/pkg/cache/context.go b/pkg/cache/context.go
index a59b224e..550eaf62 100644
--- a/pkg/cache/context.go
+++ b/pkg/cache/context.go
@@ -904,29 +904,6 @@ func (ctx *Context) StartPodAllocation(podKey string, 
nodeID string) bool {
        return ctx.schedulerCache.StartPodAllocation(podKey, nodeID)
 }
 
-// inform the scheduler that the application is completed,
-// the complete state may further explained to completed_with_errors(failed) 
or successfully_completed,
-// either way we need to release all allocations (if exists) for this 
application
-func (ctx *Context) NotifyApplicationComplete(appID string) {
-       if app := ctx.GetApplication(appID); app != nil {
-               log.Log(log.ShimContext).Debug("NotifyApplicationComplete",
-                       zap.String("appID", appID),
-                       zap.String("currentAppState", 
app.GetApplicationState()))
-               ev := NewSimpleApplicationEvent(appID, CompleteApplication)
-               dispatcher.Dispatch(ev)
-       }
-}
-
-func (ctx *Context) NotifyApplicationFail(appID string) {
-       if app := ctx.GetApplication(appID); app != nil {
-               log.Log(log.ShimContext).Debug("NotifyApplicationFail",
-                       zap.String("appID", appID),
-                       zap.String("currentAppState", 
app.GetApplicationState()))
-               ev := NewSimpleApplicationEvent(appID, FailApplication)
-               dispatcher.Dispatch(ev)
-       }
-}
-
 func (ctx *Context) NotifyTaskComplete(appID, taskID string) {
        ctx.lock.Lock()
        defer ctx.lock.Unlock()


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to