Skip to content

Commit

Permalink
chore: review comments
Browse files Browse the repository at this point in the history
  • Loading branch information
achettyiitr committed Dec 3, 2024
1 parent 0691db7 commit c1b39f2
Show file tree
Hide file tree
Showing 2 changed files with 1 addition and 3 deletions.
2 changes: 0 additions & 2 deletions src/v0/destinations/snowpipe_streaming/transform.js
Original file line number Diff line number Diff line change
Expand Up @@ -5,14 +5,12 @@ const provider = 'snowpipe_streaming';

function process(event) {
const whSchemaVersion = event.request.query.whSchemaVersion || 'v1';
const whIDResolve = event.request.query.whIDResolve === 'true' || false;
const whStoreEvent = event.destination.Config.storeFullEvent === true;
const destJsonPaths = event.destination?.Config?.jsonPaths || '';
return processWarehouseMessage(event.message, {
metadata: event.metadata,
whSchemaVersion,
whStoreEvent,
whIDResolve,
getDataTypeOverride: transform.getDataTypeOverride,
provider,
sourceCategory: event.metadata ? event.metadata.sourceCategory : null,
Expand Down
2 changes: 1 addition & 1 deletion src/warehouse/identity.js
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@ const _ = require('lodash');
const { InstrumentationError } = require('@rudderstack/integrations-lib');
const { getVersionedUtils } = require('./util');

const identityEnabledWarehouses = ['snowflake', 'snowpipe_streaming', 'bq'];
const identityEnabledWarehouses = ['snowflake', 'bq'];
const versionedMergePropColumns = {};
const versionedMergeRuleTableNames = {};

Expand Down

0 comments on commit c1b39f2

Please sign in to comment.