Skip to content

Commit

Permalink
prettier
Browse files Browse the repository at this point in the history
  • Loading branch information
Jake Ferrero committed May 17, 2024
1 parent 16d5d11 commit b5351c9
Show file tree
Hide file tree
Showing 5 changed files with 17 additions and 23 deletions.
4 changes: 2 additions & 2 deletions packages/integration-sdk-cli/src/bocchi/actions/steps.ts
Original file line number Diff line number Diff line change
Expand Up @@ -12,6 +12,6 @@ function determineTypeOfStep(step: Step): string {
? StepType.CHILD_SINGLETON
: StepType.SINGLETON
: step.parentAssociation
? StepType.FETCH_CHILD_ENTITIES
: StepType.FETCH_ENTITIES;
? StepType.FETCH_CHILD_ENTITIES
: StepType.FETCH_ENTITIES;
}
Original file line number Diff line number Diff line change
Expand Up @@ -102,11 +102,10 @@ export function generateIngestionSourcesConfig<
return;
}
// Get the dependent steps for the given matchedIntegrationStepIds
const childIngestionSources = integrationSteps.filter(
(step) =>
step.dependsOn?.some((value) =>
matchedIntegrationStepIds.includes(value),
),
const childIngestionSources = integrationSteps.filter((step) =>
step.dependsOn?.some((value) =>
matchedIntegrationStepIds.includes(value),
),
);
// Generate ingestionConfig with the childIngestionSources
newIngestionConfig[key] = {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -189,8 +189,8 @@ function generateEntity({
entity.active = isActive
? true // if
: isInactive
? false // else if
: undefined; // else
? false // else if
: undefined; // else
}

// Remove transferred `source.tags` property from the entity. `tags` is in the
Expand Down
13 changes: 5 additions & 8 deletions packages/integration-sdk-runtime/src/execution/jobState.ts
Original file line number Diff line number Diff line change
Expand Up @@ -175,14 +175,11 @@ export function createStepJobState({
});
}

await graphObjectStore.addEntities(
stepId,
entities,
async (entities) =>
uploader?.enqueue({
entities,
relationships: [],
}),
await graphObjectStore.addEntities(stepId, entities, async (entities) =>
uploader?.enqueue({
entities,
relationships: [],
}),
);

if (afterAddEntity) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -845,9 +845,8 @@ describe('flush callbacks', () => {
// disk
expect(flushedEntitiesCollected).toEqual(entities);

const allWrittenStepData = await getStorageDirectoryDataForStep(
integrationStepId,
);
const allWrittenStepData =
await getStorageDirectoryDataForStep(integrationStepId);
expect(allWrittenStepData.entities.length).toEqual(3);
expect(allWrittenStepData.relationships.length).toEqual(0);

Expand Down Expand Up @@ -952,9 +951,8 @@ describe('flush callbacks', () => {
// disk
expect(flushedRelationshipsCollected).toEqual(relationships);

const allWrittenStepData = await getStorageDirectoryDataForStep(
integrationStepId,
);
const allWrittenStepData =
await getStorageDirectoryDataForStep(integrationStepId);
expect(allWrittenStepData.relationships.length).toEqual(3);
expect(allWrittenStepData.entities.length).toEqual(0);

Expand Down

0 comments on commit b5351c9

Please sign in to comment.