diff --git a/agent-go/executor/HarborExecutor.go b/agent-go/executor/HarborExecutor.go index 18accdf..f979eb2 100644 --- a/agent-go/executor/HarborExecutor.go +++ b/agent-go/executor/HarborExecutor.go @@ -289,17 +289,19 @@ func (hOp *HarborOperator) SyncProjectExec(funcArgs []string) (bool, []string) { // 在源 Harbor 中创建复制策略 log.Info("[Harbor Sync Project ] - Start To Sync Project !") - existReplicationPolicy, err := targetClient.GetReplicationPolicyByName(ctx, octopusReplicationPolicy.Name) + policies, err := targetClient.ListReplicationPolicies(ctx) if err != nil { return false, []string{ "[Harbor Sync Project ] - get exists replication policy failed !", } } - if existReplicationPolicy != nil { - err := targetClient.DeleteReplicationPolicyByID(ctx, existReplicationPolicy.ID) - if err != nil { - return false, []string{ - "[Harbor Sync Project ] - delete exists replication policy failed !", + for _, policy := range policies { + if policy.Name == octopusReplicationPolicy.Name { + err := targetClient.DeleteReplicationPolicyByID(ctx, policy.ID) + if err != nil { + return false, []string{ + "[Harbor Sync Project ] - delete exists replication policy failed !", + } } } }