Fix panic in task scheduling

ydb-platform · Jan 10, 2025 · 7e4c9af · 7e4c9af
1 parent d229890
commit 7e4c9af
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
diff --git a/cloud/disk_manager/internal/pkg/dataplane/register.go b/cloud/disk_manager/internal/pkg/dataplane/register.go
@@ -90,7 +90,7 @@ func RegisterForExecution(
 	}
 
 	if migrationDestinationStorage != nil {
-		err = taskRegistry.Register("dataplane.MigrateSnapshotToAnotherDatabaseTask", func() tasks.Task {
+		err = taskRegistry.RegisterForExecution("dataplane.MigrateSnapshotToAnotherDatabaseTask", func() tasks.Task {
 			return &migrateSnapshotToAnotherDatabaseTask{
 				sourceStorage:      storage,
 				destinationStorage: migrationDestinationStorage,

diff --git a/cloud/disk_manager/pkg/admin/snapshots.go b/cloud/disk_manager/pkg/admin/snapshots.go
@@ -278,7 +278,8 @@ func (c *scheduleCreateSnapshotFromLegacySnapshotTask) run() error {
 	logging.Info(ctx, "Creating task scheduler")
 	taskRegistry := tasks.NewRegistry()
 
-	*(c.serverConfig.TasksConfig).RegularSystemTasksEnabled = false
+	regularSystemTasksEnabled := false
+	c.serverConfig.TasksConfig.RegularSystemTasksEnabled = &regularSystemTasksEnabled
 	taskScheduler, err := tasks.NewScheduler(
 		ctx,
 		taskRegistry,
@@ -362,7 +363,8 @@ func (c *scheduleMigrateSnapshotToAnotherDatabaseTaskCmd) run() error {
 	logging.Info(ctx, "Creating task scheduler")
 	taskRegistry := tasks.NewRegistry()
 
-	*(c.serverConfig.TasksConfig).RegularSystemTasksEnabled = false
+	regularSystemTasksEnabled := false
+	c.serverConfig.TasksConfig.RegularSystemTasksEnabled = &regularSystemTasksEnabled
 	taskScheduler, err := tasks.NewScheduler(
 		ctx,
 		taskRegistry,