package ticdc

import (
	"context"

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

func RunRegionalTiCDCChangefeedWorker(ctx context.Context) error {
	return multierr.Combine(
		container.Global().RegionalTiCDCChangefeedWorker.SyncAllChangefeed(ctx),
	)
}