diff --git a/node/modules/storageminer.go b/node/modules/storageminer.go
index bec2b7664..c5d8e7e54 100644
--- a/node/modules/storageminer.go
+++ b/node/modules/storageminer.go
@@ -300,6 +300,7 @@ func NewProviderDAGServiceDataTransfer(lc fx.Lifecycle, h host.Host, gs dtypes.S
 	dt.OnReady(marketevents.ReadyLogger("provider data transfer"))
 	lc.Append(fx.Hook{
 		OnStart: func(ctx context.Context) error {
+			dt.SubscribeToEvents(marketevents.DataTransferLogger)
 			return dt.Start(ctx)
 		},
 		OnStop: func(ctx context.Context) error {