diff --git a/cmd/trcli/activate/activate.go b/cmd/trcli/activate/activate.go
index 93f6e692..5d3c7844 100644
--- a/cmd/trcli/activate/activate.go
+++ b/cmd/trcli/activate/activate.go
@@ -68,7 +68,10 @@ func RunActivate(
 		op,
 		cp,
 		*transfer,
-		registry,
+		registry.WithTags(map[string]string{
+			"resource_id": transfer.ID,
+			"name":        transfer.TransferName,
+		}),
 	)
 
 	if err != nil {
diff --git a/cmd/trcli/replicate/replicate.go b/cmd/trcli/replicate/replicate.go
index 0f5d989e..d2ce2fa4 100644
--- a/cmd/trcli/replicate/replicate.go
+++ b/cmd/trcli/replicate/replicate.go
@@ -49,7 +49,15 @@ func RunReplication(cp coordinator.Coordinator, transfer *model.Transfer, regist
 		return xerrors.Errorf("unable to adapt transfer: %w", err)
 	}
 	for {
-		worker := local.NewLocalWorker(cp, transfer, registry, logger.Log)
+		worker := local.NewLocalWorker(
+			cp,
+			transfer,
+			registry.WithTags(map[string]string{
+				"resource_id": transfer.ID,
+				"name":        transfer.TransferName,
+			}),
+			logger.Log,
+		)
 		err := worker.Run()
 		if abstract.IsFatal(err) {
 			return err
diff --git a/cmd/trcli/upload/upload.go b/cmd/trcli/upload/upload.go
index 74731483..d9267d3d 100644
--- a/cmd/trcli/upload/upload.go
+++ b/cmd/trcli/upload/upload.go
@@ -54,6 +54,9 @@ func RunUpload(cp coordinator.Coordinator, transfer *model.Transfer, tables *con
 		*transfer,
 		nil,
 		tasks.UploadSpec{Tables: tables.Tables},
-		registry,
+		registry.WithTags(map[string]string{
+			"resource_id": transfer.ID,
+			"name":        transfer.TransferName,
+		}),
 	)
 }