diff --git a/platform/csv/pool.go b/platform/csv/pool.go
index 9705dc93..56d443ea 100644
--- a/platform/csv/pool.go
+++ b/platform/csv/pool.go
@@ -82,7 +82,7 @@ func ProcessJob(ctx context.Context, file_id int32) error {
 	_, err = psql.Update(
 		um.Table("fileupload.csv"),
 		um.SetCol("rowcount").ToArg(len(pools)),
-		um.Where(psql.Quote("id").EQ(psql.Arg(file_id))),
+		um.Where(psql.Quote("file_id").EQ(psql.Arg(file_id))),
 	).Exec(ctx, txn)
 	if err != nil {
 		return fmt.Errorf("update csv row: %w", err)