Skip to content

Commit 95c0f95

Browse files
committed
Reverted needless changes.
1 parent 62ef8f8 commit 95c0f95

File tree

1 file changed

+9
-6
lines changed

1 file changed

+9
-6
lines changed

pkg/controller/queuejob/queuejob_controller_ex.go

Lines changed: 9 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1336,13 +1336,16 @@ func (qjm *XController) ScheduleNext() {
13361336
// Update AppWrappers in etcd
13371337
// todo: This is a current workaround for duplicate message bug.
13381338
func (cc *XController) updateEtcd(qj *arbv1.AppWrapper, at string) error {
1339-
apiCacheAWJob, e := cc.queueJobLister.AppWrappers(qj.Namespace).Get(qj.Name)
1340-
if e != nil {
1341-
klog.Errorf("[updateEtcd] Failed to update status of AppWrapper %s, namespace: %s at %s err=%v",
1342-
apiCacheAWJob.Name, apiCacheAWJob.Namespace, at, e)
1343-
return e
1344-
}
1339+
//apiCacheAWJob, e := cc.queueJobLister.AppWrappers(qj.Namespace).Get(qj.Name)
1340+
//
1341+
//if (e != nil) {
1342+
// klog.Errorf("[updateEtcd] Failed to update status of AppWrapper %s, namespace: %s at %s err=%v",
1343+
// apiCacheAWJob.Name, apiCacheAWJob.Namespace, at, e)
1344+
// return e
1345+
//}
13451346

1347+
//TODO: Remove next line
1348+
var apiCacheAWJob *arbv1.AppWrapper
13461349
//TODO: Remove next line
13471350
apiCacheAWJob = qj
13481351
apiCacheAWJob.Status.Sender = "before " + at // set Sender string to indicate code location

0 commit comments

Comments
 (0)