From 914b76069fac8d95b9b9668ef2f39b4a89c12987 Mon Sep 17 00:00:00 2001 From: Qu Xuan Date: Fri, 16 Oct 2020 10:40:18 +0800 Subject: [PATCH] fix: sync dns records after sync vpcs --- pkg/compute/tasks/dnszone_sync_vpcs_task.go | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/pkg/compute/tasks/dnszone_sync_vpcs_task.go b/pkg/compute/tasks/dnszone_sync_vpcs_task.go index 26b686bc12..22ccc0b45c 100644 --- a/pkg/compute/tasks/dnszone_sync_vpcs_task.go +++ b/pkg/compute/tasks/dnszone_sync_vpcs_task.go @@ -146,5 +146,14 @@ func (self *DnsZoneSyncVpcsTask) OnInit(ctx context.Context, obj db.IStandaloneM } } + self.SetStage("OnSyncRecordSetComplete", nil) + dnsZone.StartDnsZoneSyncRecordSetsTask(ctx, self.GetUserCred(), self.GetTaskId()) +} + +func (self *DnsZoneSyncVpcsTask) OnSyncRecordSetComplete(ctx context.Context, dnsZone *models.SDnsZone, data jsonutils.JSONObject) { self.taskComplete(ctx, dnsZone) } + +func (self *DnsZoneSyncVpcsTask) OnSyncRecordSetCompleteFailed(ctx context.Context, cache *models.SDnsZoneCache, data jsonutils.JSONObject) { + self.SetStageFailed(ctx, data) +}