diff --git a/ingestion/examples/workflows/redshift.json b/ingestion/examples/workflows/redshift.json
index 92a37033a13..48c3e41e515 100644
--- a/ingestion/examples/workflows/redshift.json
+++ b/ingestion/examples/workflows/redshift.json
@@ -9,7 +9,8 @@
       "service_name": "aws_redshift",
       "table_filter_pattern": {
         "excludes": ["information_schema.*", "[\\w]*event_vw.*"]
-      }
+      },
+      "query":"select * from \"{}\".\"{}\" Limit 50"
     }
   },
   "sink": {
diff --git a/ingestion/src/metadata/ingestion/source/redshift.py b/ingestion/src/metadata/ingestion/source/redshift.py
index 624311d8955..950a08e4770 100644
--- a/ingestion/src/metadata/ingestion/source/redshift.py
+++ b/ingestion/src/metadata/ingestion/source/redshift.py
@@ -224,6 +224,7 @@ class RedshiftConfig(SQLConnectionConfig):
     where_clause: Optional[str] = None
     duration: int = 1
     service_type = DatabaseServiceType.Redshift.value
+    query = 'select * from "{}"."{}"'
 
     def get_identifier(self, schema: str, table: str) -> str:
         """