package replay

import (
	"context"

	"github.com/tidbcloud/dataflow-service/app/container"
	"go.uber.org/multierr"
)

// RunSyncReplayWorker sync the replay task status
func RunSyncReplayWorker(ctx context.Context) error {
	return multierr.Combine(
		container.Global().ReplayWorker.SyncAllReplays(ctx),
	)
}