Format

JupiterOne · Dec 4, 2024 · f7f75f6 · f7f75f6
1 parent 106c2a1
commit f7f75f6
Showing 1 changed file with 21 additions and 15 deletions.
diff --git 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<TIntegrationConfig>,
@@ -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.`,
           );
         }
       });