diff --git a/src/controller/gc/controller.go b/src/controller/gc/controller.go
index ab34a604105..8ade07f3fc8 100644
--- a/src/controller/gc/controller.go
+++ b/src/controller/gc/controller.go
@@ -205,6 +205,7 @@ func (c *controller) GetSchedule(ctx context.Context) (*scheduler.Schedule, erro
 func (c *controller) CreateSchedule(ctx context.Context, cronType, cron string, policy Policy) (int64, error) {
 	extras := make(map[string]interface{})
 	extras["delete_untagged"] = policy.DeleteUntagged
+	extras["workers"] = policy.Workers
 	return c.schedulerMgr.Schedule(ctx, job.GarbageCollectionVendorType, -1, cronType, cron, job.GarbageCollectionVendorType, policy, extras)
 }
 
diff --git a/src/controller/gc/controller_test.go b/src/controller/gc/controller_test.go
index 02f3af0c4eb..857f4ecff74 100644
--- a/src/controller/gc/controller_test.go
+++ b/src/controller/gc/controller_test.go
@@ -150,6 +150,7 @@ func (g *gcCtrTestSuite) TestCreateSchedule() {
 	p := Policy{
 		DeleteUntagged: true,
 		ExtraAttrs:     dataMap,
+		Workers:        3,
 	}
 	id, err := g.ctl.CreateSchedule(nil, "Daily", "* * * * * *", p)
 	g.Nil(err)