add organization id in salesforce connection

open-metadata · Sep 19, 2024 · dc655b1 · dc655b1
1 parent 7a2b091
commit dc655b1
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 4 deletions.
diff --git a/ingestion/src/metadata/examples/workflows/salesforce.yaml b/ingestion/src/metadata/examples/workflows/salesforce.yaml
@@ -7,6 +7,7 @@ source:
  username: username
  password: password
  securityToken: securityToken
+ organizationId: organizationId
  sobjectName: sobjectName
  # sslConfig:
  # caCertificate: |

diff --git a/ingestion/src/metadata/ingestion/source/database/salesforce/connection.py b/ingestion/src/metadata/ingestion/source/database/salesforce/connection.py
@@ -32,12 +32,11 @@ def get_connection(connection: SalesforceConnection):
  """
  return Salesforce(
  username=connection.username,
- password=connection.password.get_secret_value()
- if connection.password
- else None,
+ password=connection.password.get_secret_value(),
  security_token=connection.securityToken.get_secret_value()
  if connection.securityToken
- else None,
+ else "",
+ organizationId=connection.organizationId if connection.organizationId else "",
  domain=connection.salesforceDomain,
  version=connection.salesforceApiVersion,
  **connection.connectionArguments.root if connection.connectionArguments else {},

diff --git a/...main/resources/json/schema/entity/services/connections/database/salesforceConnection.json b/...main/resources/json/schema/entity/services/connections/database/salesforceConnection.json
@@ -37,6 +37,11 @@
  "type": "string",
  "format": "password"
  },
+ "organizationId": {
+ "title": "Salesforce Organization ID",
+ "description": "Salesforce Organization ID is the unique identifier for your Salesforce identity",
+ "type": "string"
+ },
  "sobjectName": {
  "title": "Object Name",
  "description": "Salesforce Object Name.",