#1228 update accout failed, make panic
diff --git a/syncer/service/replicator/resource/account.go b/syncer/service/replicator/resource/account.go
index a36bfcd..a0c6ee2 100644
--- a/syncer/service/replicator/resource/account.go
+++ b/syncer/service/replicator/resource/account.go
@@ -85,6 +85,7 @@
},
resourceID: a.input.Name,
}
+ c.tombstoneLoader = c
return c.needOperate(ctx)
}
diff --git a/syncer/service/task/manager.go b/syncer/service/task/manager.go
index e03e7bc..52fb7b6 100644
--- a/syncer/service/task/manager.go
+++ b/syncer/service/task/manager.go
@@ -164,6 +164,8 @@
return nil, err
}
+ metrics.PendingTaskSet(int64(len(tasks)))
+
noHandleTasks := make([]*carisync.Task, 0, len(tasks))
skipTaskIDs := make([]string, 0, len(tasks))
for _, t := range tasks {
@@ -258,8 +260,6 @@
func (m *manager) handleTasks(sts syncTasks) {
sort.Sort(sts)
- metrics.PendingTaskSet(int64(len(sts)))
-
for _, st := range sts {
m.eventSender.Send(toEvent(st, m.result))
}
