From f7f75f62c1c6ed48f95bdb6a3dc0671df025521d Mon Sep 17 00:00:00 2001 From: Gonzalo Avalos Ribas Date: Wed, 4 Dec 2024 17:50:25 -0300 Subject: [PATCH] Format --- .../src/execution/executeIntegration.ts | 36 +++++++++++-------- 1 file changed, 21 insertions(+), 15 deletions(-) diff --git a/packages/integration-sdk-runtime/src/execution/executeIntegration.ts b/packages/integration-sdk-runtime/src/execution/executeIntegration.ts index 7ee2510b..eb99727b 100644 --- a/packages/integration-sdk-runtime/src/execution/executeIntegration.ts +++ b/packages/integration-sdk-runtime/src/execution/executeIntegration.ts @@ -107,7 +107,7 @@ export async function executeIntegrationLocally( */ export async function executeIntegrationInstance< TIntegrationConfig extends - IntegrationInstanceConfig = IntegrationInstanceConfig, + IntegrationInstanceConfig = IntegrationInstanceConfig, >( logger: IntegrationLogger, instance: IntegrationInstance, @@ -238,16 +238,19 @@ export async function executeWithContext< validateStepStartStates(config.integrationSteps, configStepStartStates); - logger.info({ - integrationSteps: config.integrationSteps.filter( - (step) => step.id === DEBUG_STEP_ID, - ), - configStepStartStates: configStepStartStates[DEBUG_STEP_ID], - instanceDisabledSources: context.instance?.disabledSources?.filter( - (step) => step.ingestionSourceId === DEBUG_STEP_ID, - ), - stepStartStatesInConfig: stepStartStatesInConfig?.[DEBUG_STEP_ID], - }, 'Calculating step start states'); + logger.info( + { + integrationSteps: config.integrationSteps.filter( + (step) => step.id === DEBUG_STEP_ID, + ), + configStepStartStates: configStepStartStates[DEBUG_STEP_ID], + instanceDisabledSources: context.instance?.disabledSources?.filter( + (step) => step.ingestionSourceId === DEBUG_STEP_ID, + ), + stepStartStatesInConfig: stepStartStatesInConfig?.[DEBUG_STEP_ID], + }, + 'Calculating step start states', + ); const stepStartStates = getIngestionSourceStepStartStates({ integrationSteps: config.integrationSteps, @@ -257,9 +260,12 @@ export async function executeWithContext< ), }); - logger.info({ - stepStartStates: stepStartStates[DEBUG_STEP_ID], - }, `Step start states calculated`); + logger.info( + { + stepStartStates: stepStartStates[DEBUG_STEP_ID], + }, + `Step start states calculated`, + ); if (shouldPublishDiskUsageMetric) { diskUsagePublishInterval = createDiskUsagePublishInterval(); @@ -350,7 +356,7 @@ export async function executeWithContext< context.logger.error( { undeclaredTypes, stepId: step.id }, `Undeclared types detected during execution. To prevent accidental data loss, please ensure that` + - ` all known entity and relationship types are declared.`, + ` all known entity and relationship types are declared.`, ); } });