feat: disable pgbackrest timestamp logging

Our task logs have a separate `timestamp` field, so disabling these
timestamps will make the task logs easier to consume consistently.

PLAT-33

Author: jason-lynch

server/internal/orchestrator/swarm/pgbackrest_restore.go

@@ -230,6 +230,7 @@ func (p *PgBackRestRestore) runRestoreContainer(
 		limits = *swarmService.Spec.TaskTemplate.Resources.Limits
 	}
 	containerSpec := swarmService.Spec.TaskTemplate.ContainerSpec
+	opts := append([]string{"--log-timestamp=n"}, p.Options...)
 	containerID, err := dockerClient.ContainerRun(ctx, docker.ContainerRunOptions{
 		Config: &container.Config{
 			Image: containerSpec.Image,
@@ -240,7 +241,7 @@ func (p *PgBackRestRestore) runRestoreContainer(
 				"pgedge.component":   "pgbackrest-restore",
 			},
 			Hostname:   containerSpec.Hostname,
-			Entrypoint: PgBackRestRestoreCmd("restore", p.Options...).StringSlice(),
+			Entrypoint: PgBackRestRestoreCmd("restore", opts...).StringSlice(),
 		},
 		Host: &container.HostConfig{
 			Mounts: containerSpec.Mounts,

server/internal/pgbackrest/cmd.go

@@ -55,8 +55,10 @@ type BackupOptions struct {
 }
 
 func (b BackupOptions) StringSlice() []string {
-	var options []string
-	options = append(options, "--type", b.Type.String())
+	options := []string{
+		"--log-timestamp=n",
+		"--type", b.Type.String(),
+	}
 	for k, v := range b.Annotations {
 		options = append(options, "--annotation", k+"="+v)
 	}

server/internal/workflows/activities/delete_db_entities.go

@@ -13,12 +13,10 @@ import (
 
 	"github.com/pgEdge/control-plane/server/internal/database"
 	"github.com/pgEdge/control-plane/server/internal/resource"
-	"github.com/pgEdge/control-plane/server/internal/task"
 )
 
 type DeleteDbEntitiesInput struct {
-	DatabaseID   uuid.UUID `json:"database_id"`
-	DeleteTaskID uuid.UUID `json:"delete_task_id"`
+	DatabaseID uuid.UUID `json:"database_id"`
 }
 
 type DeleteDbEntitiesOutput struct{}
@@ -57,21 +55,6 @@ func (a *Activities) DeleteDbEntities(ctx context.Context, input *DeleteDbEntiti
 	if err != nil && !errors.Is(err, database.ErrDatabaseNotFound) {
 		return nil, fmt.Errorf("failed to delete database: %w", err)
 	}
-	tasks, err := a.TaskSvc.GetTasks(ctx, input.DatabaseID, task.TaskListOptions{})
-	if err != nil {
-		return nil, fmt.Errorf("failed to list tasks: %w", err)
-	}
-	for _, t := range tasks {
-		// We want to leave the delete task in place so that API clients can
-		// track the delete through to completion.
-		if t.TaskID == input.DeleteTaskID {
-			continue
-		}
-		err = a.TaskSvc.DeleteTask(ctx, input.DatabaseID, t.TaskID)
-		if err != nil {
-			return nil, fmt.Errorf("failed to delete task: %w", err)
-		}
-	}
 
 	return &DeleteDbEntitiesOutput{}, nil
 }

server/internal/workflows/delete_database.go

@@ -77,8 +77,7 @@ func (w *Workflows) DeleteDatabase(ctx workflow.Context, input *DeleteDatabaseIn
 	}
 
 	deleteInput := &activities.DeleteDbEntitiesInput{
-		DatabaseID:   input.DatabaseID,
-		DeleteTaskID: input.TaskID,
+		DatabaseID: input.DatabaseID,
 	}
 	_, err = w.Activities.ExecuteDeleteDbEntities(ctx, deleteInput).Get(ctx)
 	if err != nil {