🎉 Allow non-default source SFTP port (#4953)

* Allow SFTP to define port

* Define port as a string

* Provide a clearer error if port parsing fails

airbyte-integrations/connectors/source-file/source_file/client.py

@@ -119,7 +119,13 @@ def _open(self, binary):
         elif storage in ("ssh://", "scp://", "sftp://"):
             user = self._provider["user"]
             host = self._provider["host"]
-            port = self._provider.get("port", 22)
+            # TODO: Remove int casting when https://github.com/airbytehq/airbyte/issues/4952 is addressed
+            # TODO: The "port" field in spec.json must also be changed
+            _port_value = self._provider.get("port", 22)
+            try:
+                port = int(_port_value)
+            except ValueError as err:
+                raise ValueError(f"{_port_value} is not a valid integer for the port") from err
             # Explicitly turn off ssh keys stored in ~/.ssh
             transport_params = {"connect_kwargs": {"look_for_keys": False}}
             if "password" in self._provider:

airbyte-integrations/connectors/source-file/source_file/spec.json

@@ -123,8 +123,8 @@
                 "type": "string"
               },
               "port": {
-                "type": "number",
-                "default": 22
+                "type": "string",
+                "default": "22"
               }
             }
           },
@@ -148,8 +148,8 @@
                 "type": "string"
               },
               "port": {
-                "type": "number",
-                "default": 22
+                "type": "string",
+                "default": "22"
               }
             }
           },
@@ -171,6 +171,10 @@
               },
               "host": {
                 "type": "string"
+              },
+              "port": {
+                "type": "string",
+                "default": "22"
               }
             }
           },