Merge pull request #24 from razorpay/airflow_fix

DE-6380 checking if schema defined
razorpay · Jul 24, 2024 · 6f1b8a3 · 6f1b8a3
2 parents a771ba4 + af793e0
commit 6f1b8a3
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sql-delta-import/src/main/scala/com/razorpay/spark/jdbc/JDBCImport.scala b/sql-delta-import/src/main/scala/com/razorpay/spark/jdbc/JDBCImport.scala
@@ -62,7 +62,7 @@ case class ImportConfig(
 
   var inputTableEscaped: String = escapeCharacter + inputTable + escapeCharacter
 
-  if (dbType == Constants.POSTGRESQL){
+  if (dbType == Constants.POSTGRESQL && schema.isDefined){
     inputTableEscaped = schema.get + "."+ inputTableEscaped
   }