diff --git a/packages/destination-actions/src/destinations/liveramp-audiences/audienceEntered/index.ts b/packages/destination-actions/src/destinations/liveramp-audiences/audienceEntered/index.ts index 20d4e3ae85..364a29c35d 100644 --- a/packages/destination-actions/src/destinations/liveramp-audiences/audienceEntered/index.ts +++ b/packages/destination-actions/src/destinations/liveramp-audiences/audienceEntered/index.ts @@ -57,7 +57,7 @@ const action: ActionDefinition = { description: 'Maximum number of events to include in each batch. Actual batch sizes may be lower.', type: 'number', required: false, - default: 100000 + default: 1000000 } }, perform: async (request, { settings, payload }) => { diff --git a/packages/destination-actions/src/destinations/liveramp-audiences/audienceEntered/sftp.ts b/packages/destination-actions/src/destinations/liveramp-audiences/audienceEntered/sftp.ts index be2042a332..a47f480e5b 100644 --- a/packages/destination-actions/src/destinations/liveramp-audiences/audienceEntered/sftp.ts +++ b/packages/destination-actions/src/destinations/liveramp-audiences/audienceEntered/sftp.ts @@ -35,13 +35,16 @@ async function doSFTP(sftp: Client, settings: Settings, action: { (sftp: Client) password: settings.sftp_password }) - await action(sftp) + const retVal = await action(sftp) await sftp.end() + return retVal } async function testAuthenticationSFTP(sftp: Client, settings: Settings) { return doSFTP(sftp, settings, async (sftp) => { - return sftp.list(settings.sftp_folder_path as string) + return sftp.exists(settings.sftp_folder_path as string).then((fileType) => { + if (!fileType) throw new Error(`Could not find path: ${settings.sftp_folder_path}`) + }) }) } diff --git a/packages/destination-actions/src/destinations/liveramp-audiences/index.ts b/packages/destination-actions/src/destinations/liveramp-audiences/index.ts index 48304a17d8..e661c44869 100644 --- a/packages/destination-actions/src/destinations/liveramp-audiences/index.ts +++ b/packages/destination-actions/src/destinations/liveramp-audiences/index.ts @@ -79,7 +79,7 @@ const destination: DestinationDefinition = { // S3 authentication is skipped to avoid requiring a GetObject permission on the IAM role. if (settings.upload_mode == 'SFTP') { const sftpClient = new ClientSFTP() - await testAuthenticationSFTP(sftpClient, settings) + return await testAuthenticationSFTP(sftpClient, settings) } } },