Skip to content

Commit

Permalink
chore(CE): Change title of AIS Data Store (#585) (#477)
Browse files Browse the repository at this point in the history
Co-authored-by: TivonB-AI2
  • Loading branch information
github-actions[bot] authored Nov 18, 2024
1 parent 554565a commit 4d7d496
Show file tree
Hide file tree
Showing 6 changed files with 23 additions and 23 deletions.
2 changes: 1 addition & 1 deletion integrations/Gemfile.lock
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@ GIT
PATH
remote: .
specs:
multiwoven-integrations (0.15.2)
multiwoven-integrations (0.15.4)
MailchimpMarketing
activesupport
async-websocket
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -35,7 +35,7 @@ def discover(connection_config)
catalog.to_multiwoven_message
rescue StandardError => e
handle_exception(e, {
context: "POSTGRESQL:DISCOVER:EXCEPTION",
context: "AIS:DATA:STORE:DISCOVER:EXCEPTION",
type: "error"
})
ensure
Expand All @@ -54,14 +54,14 @@ def write(sync_config, records, action = "destination_insert")

records.each do |record|
query = Multiwoven::Integrations::Core::QueryBuilder.perform(action, table_name, record, primary_key)
logger.debug("POSTGRESQL:WRITE:QUERY query = #{query} sync_id = #{sync_config.sync_id} sync_run_id = #{sync_config.sync_run_id}")
logger.debug("AIS:DATA:STORE:WRITE:QUERY query = #{query} sync_id = #{sync_config.sync_id} sync_run_id = #{sync_config.sync_run_id}")
begin
response = db.exec(query)
write_success += 1
log_message_array << log_request_response("info", query, response)
rescue StandardError => e
handle_exception(e, {
context: "POSTGRESQL:RECORD:WRITE:EXCEPTION",
context: "AIS:DATA:STORE:RECORD:WRITE:EXCEPTION",
type: "error",
sync_id: sync_config.sync_id,
sync_run_id: sync_config.sync_run_id
Expand All @@ -73,7 +73,7 @@ def write(sync_config, records, action = "destination_insert")
tracking_message(write_success, write_failure, log_message_array)
rescue StandardError => e
handle_exception(e, {
context: "POSTGRESQL:RECORD:WRITE:EXCEPTION",
context: "AIS:DATA:STORE:RECORD:WRITE:EXCEPTION",
type: "error",
sync_id: sync_config.sync_id,
sync_run_id: sync_config.sync_run_id
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@
"connector_type": "destination",
"category": "Database",
"documentation_url": "https://docs.mutliwoven.com",
"github_issue_label": "destination-postgresql",
"github_issue_label": "destination-ais-data-store",
"icon": "icon.svg",
"license": "MIT",
"release_stage": "alpha",
Expand Down
Original file line number Diff line number Diff line change
@@ -1,9 +1,9 @@
{
"documentation_url": "https://docs.multiwoven.com/integrations/sources/postgresql",
"documentation_url": "https://docs.multiwoven.com/integrations/destination/ais-data-store",
"stream_type": "dynamic",
"connection_specification": {
"$schema": "http://json-schema.org/draft-07/schema#",
"title": "Postgresql",
"title": "AIS Data Store",
"type": "object",
"required": ["host", "port", "database", "schema"],
"properties": {
Expand All @@ -19,8 +19,8 @@
"readOnly": true
},
"username": {
"description": "Username refers to your individual PostgreSQL login credentials. At a minimum, the user associated with these credentials must be granted read access to the data intended for synchronization.",
"examples": ["POSTGRESQL_USER"],
"description": "Username refers to your individual AIS Data Store login credentials. At a minimum, the user associated with these credentials must be granted read access to the data intended for synchronization.",
"examples": ["AIS_DATA_STORE_USER"],
"type": "string",
"title": "Username",
"order": 1
Expand All @@ -36,29 +36,29 @@
"order": 0
},
"host": {
"description": "The hostname or IP address of your PostgreSQL server.",
"description": "The hostname or IP address of your AIS Data Store server.",
"examples": ["127.0.0.1"],
"type": "string",
"title": "Host",
"order": 1
},
"port": {
"description": "The port number for your PostgreSQL server, which defaults to 5432, may vary based on your configuration. ",
"description": "The port number for your AIS Data Store server, which defaults to 5432, may vary based on your configuration. ",
"examples": ["5432"],
"type": "string",
"title": "Port",
"order": 2
},
"database": {
"description": "The specific PostgreSQL database to connect to.",
"examples": ["POSTGRESQL_DB"],
"description": "The specific AIS Data Store database to connect to.",
"examples": ["AIS_DATA_STORE_DB"],
"type": "string",
"title": "Database",
"order": 3
},
"schema": {
"description": "The schema within the PostgreSQL database.",
"examples": ["POSTGRESQL_SCHEMA"],
"description": "The schema within the AIS Data Store database.",
"examples": ["AIS_DATA_STORE_SCHEMA"],
"type": "string",
"title": "Schema",
"order": 4
Expand Down
2 changes: 1 addition & 1 deletion integrations/lib/multiwoven/integrations/rollout.rb
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@

module Multiwoven
module Integrations
VERSION = "0.15.3"
VERSION = "0.15.4"

ENABLED_SOURCES = %w[
Snowflake
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,13 +5,13 @@
let(:sync_config) do
{
"source": {
"name": "PostgresqlSourceConnector",
"name": "AISDataStoreSourceConnector",
"type": "source",
"connection_specification": {
"credentials": {
"auth_type": "username/password",
"username": ENV["POSTGRESQL_USERNAME"],
"password": ENV["POSTGRESQL_PASSWORD"]
"username": ENV["AISDATASTORE_USERNAME"],
"password": ENV["AISDATASTORE_PASSWORD"]
},
"host": "test.pg.com",
"port": "8080",
Expand All @@ -25,8 +25,8 @@
"connection_specification": {
"credentials": {
"auth_type": "username/password",
"username": ENV["POSTGRESQL_USERNAME"],
"password": ENV["POSTGRESQL_PASSWORD"]
"username": ENV["AISDATASTORE_USERNAME"],
"password": ENV["AISDATASTORE_PASSWORD"]
},
"host": "test.pg.com",
"port": "8080",
Expand Down Expand Up @@ -192,7 +192,7 @@
allow(client).to receive(:create_connection).and_raise(StandardError.new("test error"))
expect(client).to receive(:handle_exception).with(
an_instance_of(StandardError), {
context: "POSTGRESQL:DISCOVER:EXCEPTION",
context: "AIS:DATA:STORE:DISCOVER:EXCEPTION",
type: "error"
}
)
Expand Down

0 comments on commit 4d7d496

Please sign in to comment.