Skip to content

Commit

Permalink
[AB#43807][AB#43809] releases: iteration 96 (#299)
Browse files Browse the repository at this point in the history
* [AB#42874] GraphQL subscription events are now strongly typed (#235)

* feat: subscription events are now strongly typed
[AB#42874]

* chore: fix catalog build error related to video custom_id
[AB#42909]

* [AB#42984] Add platform to docker build cmd (#238)

* fix: Add platform to docker build command

* fix: Restructure the docker build command

* style: removing delete icon from action panel

* fix: transformNavigationTree no longer crashes the navigation if no settings items are in the tree (#241)

* [AB#43264] fix: ➕ add missing deps (#246)

* fix: ➕ add missing deps into catalog-service, entitlement-service, vod-to-live-service

* [AB#41828] feat: redirect browser requests to graphiql (#250)

* feat: redirect browser requests to graphiql

* ci: fix name validation when rasing PR from vscode

* chore: Updated lib versions

* chore: Updated lib versions

* feat: transactional outbox/inbox for the media service

* chore: mosaic version upgrades

* chore: update after yarn force

* chore: increased the finished ingest doc interval

* chore: removed unused type

* feat: transactional inbox for the Catalog Service

* feat: inline auth for ChannelGuardedTransactionalMessageHandler

* chore: added missing dependency

* chore: UI lib hotfix

* chore: PR adjustments

* chore: index file adjustment

* feat: added the transactional outbox/inbox to the entitlement service

* chore: PR adjustments

* feat: The GQL role only has SELECT grants on app_public tables

* test: handler tests us now the root pool

* Adding .DS_Store to .gitignore (#258)

* fix: ⬆️ upgrade `geoip-country` lib to latest to fix entitlement-service startup errors (#256)

* feat: allow GEO IP download URL to be configured

* feat: allow GEO license key OR download URL

* feat: close template1 connections on test:reset:dbs

* chore: update libs for iteration 93

* refactor: :recycle: use the new metrics interface with the logger passed-in (#263)

* refactor: ♻️ use the new metrics interface with the logger passed-in (#263)

* fix: swtich to hotfixed tx-inbox-outbox lib

* [AB#41699] Localizations integration (#164)

* chore: include feature branch to pr checks

* chore: disable PR checks for localization feature branch

* [AB#39600] [AB#39414] [AB#39279] [AB#39062] Movies and movie genres data can now be synced with the Localization service (#80)

* feat: movies and movie genres data can now be synced with the Localization service
[AB#39600]

* chore: testing infra adjusted and packages updated
[AB#39600]

* test: adjustments
[AB#39600]

* chore: make replication slot name configurable
[AB#39600]

* chore: use nav type action for Localization links

* chore: PR review adjustments
[AB#39600]

* chore: minor adjustment to no longer use dropped message type
[AB#39600]

* chore: revert pr check changes

* chore: temp PR pipeline fix attempt

* chore: revert the PR pipeline temp fix

* chore: drop temp docker infra setup for pr checks

* chore: increase the space size for out of memory

* chore: adjust run tests build step

* chore: change max workers for jest CI runs

* chore: try 2 jest workers

* chore: try setting jest max workers to 1

* chore: use dev infra for running ci tests

* chore: run ci tests serially

* chore: temporarily disable PR builds for localization feature branch

---------

Co-authored-by: Inga Eglite <[email protected]>

* [AB#39602] channel localizations added (#115)

* feat: channel localizations are now handled and available
[AB#39602]

* chore: PR review adjustments
[AB#39602]

* [AB#39601] movie and movie genre localizations can now be published (#128)

* feature: movie and movie genre localizations can now be published
[AB#39601]

* chore: make media service to always publish localizations array
[AB#39601]

* chore: PR review adjustments
[AB#39601]

* [AB#40831] added a workaround to jest memory leak issue for CI PR builds (#138)

* fix: added a workaround to jest memory leak issue for CI PR builds
[AB#40831]

* chore: limit the amount of workers for the CI script
[AB#40831]

* chore: increase tests debug timeout to 15min

* [AB#40804] make logical replication slot name empty in .env.template (#139)

* fix: make logical replication slot name empty in template
[AB#40804]

* chore: adjust test config for CI PR builds
[AB#40804]

* [AB#40026] Localizations integrated for TV Shows, Seasons, Episodes, Collections, and TV Show Genres (#141)

* feat: localizations integrated for TV Shows, Seasons, Episodes, Collections, and TV Show Genres
[AB#40026]

* chore: PR review adjustments
[AB#40026]

* feat: ensureReplicationSlotAndPublicationExist helper used (#153)

[AB#41392]

* fix: prepareEntityLocalizationsForPublishing changed from mutation to query (#160)

[AB#41559]

* chore: localizations review (#178)

[AB#41699]

* [AB#41785] separate replication connection string for deployment scenarios (#181)

* chore: separate replication connection string used for replication service
[AB#41785]

* chore: add explicit description to replication port
[AB#41785]

* chore: remove feature branch pr build indication

* fix: entity field definition title no longer includes field word (#186)

[AB#41842]

* chore: bump integration lib and apply renaming

* chore: bump libs and renamed registerLocalizationEntryPoints

* feat: localizable properties are embedded into the root entity using views (#193)

[AB#41880]

* [AB#42059] channel localizations dropped (#195)

* feat: channel localizations dropped
[AB#42059]

* test: minor test fixes
[AB#42059]

* chore: post-rebase adjustments

* chore: increase catalog tests timeout

* chore: increase jest workers count

* chore: set jest workers to 5

* chore: set jest workers to 3 and timeout to 120s

* fix: add memory leak fix to root level jest config
[AB#40831]

* feat: catalog service whitelists custom locale header (#206)

[AB#42148]

* [AB#40605] Ingest of localizations is now supported (#211)

* feat: Ingest of localizations is now supported
[AB#40605]

* chore: pr review adjustments
[AB#40605]

* [AB#42388] inactive field source values are now synced (#216)

* feat: inactive field source values are now synced
[AB#42388]

* chore: update mosaic package versions
[AB#42388]

* chore: re-create localization migrations after rebase

* [AB#42975] logical replication approach dropped in favor of db triggers and message polling (#253)

* feat: logical replication approach dropped in favor of db triggers and message polling
[AB#42975]

* chore: PR review adjustments
[AB#42975]

* chore: feature-branch review adjustments (#254)

[AB#41699]

* chore: post-rebase catalog grants adjustments
[AB#41699]

* chore: update mosaic packages

---------

Co-authored-by: Inga Eglite <[email protected]>
Co-authored-by: Benjamin Schwendner <[email protected]>
Co-authored-by: Isuru Jayasooriya <[email protected]>

* feat: number of default seed genres reduced to 10 per type (#264)

[AB#43455]

* feat: entitlement trx outbox/inbox hosting added

* feat: Update isLocalizationEnabled if Localization Service is disabled

* feat: entitlement trx outbox/inbox hosting added

* feat: refactoring and enabling localization for hosting

* test: test fixes and improvements

* fix: explorer titles to be similar to managed workflows

* fix: refetch queries after mutations are completed

* chore: Updated library versions

* chore: Update pg-transactional-outbox version (#273)

* chore: Update pg-transactional-outbox version (#273)

* fix: Fix messaging errors

* [AB#43670] Fix mosaic lib versions (#274)

* chore: Fix mosaic lib versions

* chore: capture exit code of yarn build command

* chore: update lib versions with caret

* test: fix unit tests

---------

Co-authored-by: Anushka Liyanage <[email protected]>

* fix: make sure setup script works when service account for media service did not exist before (#275)

[AB#43685]

* fix: make sure setup script works when service account for media service did not exist before
[AB#43685]

* [AB#43742] Ingests: Edit permission is no longer required for media service account (#277)

* feat: Ingests: Edit permission is no longer required for media service account
[AB#43742]

* chore: adjust token usage in upsert finished handler and test
[AB#43742]

* chore: renamed loginClient to ownerClient in media handlers (#278)

[AB#43746]

* fix: entity titles are now fully generated for localized seasons and episodes (#279)

[AB#43767]

* fix: entity titles are now fully generated for localized seasons and episodes (#279)

[AB#43767]

* fix: added the ID service permissions to setup

* chore: Update piral to 1.5.2 (#287)

* feat: allows hiding/showing Localizations button on details using env variable (#284)

[AB#43755]

* chore: Update mosaic-portal version (#288)

* chore: update libs for iteration 96

* chore: revert service-common version to 0.48.0

---------

Co-authored-by: Sergey Trusov <[email protected]>
Co-authored-by: Yasith Ariyasena <[email protected]>
Co-authored-by: Irina Gusseva <[email protected]>
Co-authored-by: axinomirina <[email protected]>
Co-authored-by: Benjamin Schwendner <[email protected]>
Co-authored-by: Ruwan Xaviour Fernando <[email protected]>
Co-authored-by: Vindula <[email protected]>
Co-authored-by: vindulaR <[email protected]>
Co-authored-by: Frank Zehelein <[email protected]>
Co-authored-by: Oleg Knut <[email protected]>
Co-authored-by: Inga Eglite <[email protected]>
Co-authored-by: Benjamin Schwendner <[email protected]>
Co-authored-by: Isuru Jayasooriya <[email protected]>
Co-authored-by: Isuru <[email protected]>
Co-authored-by: Sergey Trusov <[email protected]>
  • Loading branch information
16 people authored May 7, 2024
1 parent 4ec6149 commit 31b988d
Show file tree
Hide file tree
Showing 64 changed files with 2,156 additions and 1,504 deletions.
6 changes: 3 additions & 3 deletions libs/media-messages/package.json
Original file line number Diff line number Diff line change
Expand Up @@ -21,8 +21,8 @@
"build:compile": "tsc"
},
"devDependencies": {
"@axinom/mosaic-cli": "^0.31.0-rc.8",
"@axinom/mosaic-message-bus-abstractions": "0.12.0-rc.8",
"@axinom/mosaic-cli": "0.32.0",
"@axinom/mosaic-message-bus-abstractions": "0.13.0",
"@types/glob": "^7.2.0",
"concurrently": "^5.3.0",
"rimraf": "^3.0.2",
Expand All @@ -31,4 +31,4 @@
"typescript": "^4.9.4",
"watch": "^1.0.2"
}
}
}
8 changes: 4 additions & 4 deletions package.json
Original file line number Diff line number Diff line change
Expand Up @@ -48,7 +48,7 @@
"yarn:de-dupe": "npx yarn-deduplicate yarn.lock"
},
"devDependencies": {
"@axinom/mosaic-cli": "^0.31.0-rc.8",
"@axinom/mosaic-cli": "0.32.0",
"@dbeining/react-atom": "^4.1.21",
"@jest/globals": "^29.5.0",
"@libre/atom": "^1.3.3",
Expand Down Expand Up @@ -81,8 +81,8 @@
"jest": "^29.5.0",
"jest-expect-message": "^1.1.3",
"jest-junit": "^14.0.1",
"piral-cli": "^0.15.8",
"piral-cli-webpack5": "^0.15.8",
"piral-cli": "^1.5.2",
"piral-cli-webpack5": "^1.5.2",
"prettier": "^2.7.1",
"prettier-plugin-organize-imports": "^3.1.1",
"prompts": "^2.4.2",
Expand All @@ -107,4 +107,4 @@
"jest": "^29",
"jest-cli": "^29"
}
}
}
16 changes: 8 additions & 8 deletions services/catalog/service/package.json
Original file line number Diff line number Diff line change
Expand Up @@ -41,14 +41,14 @@
"util:define-func-migration": "yarn mosaic generate-define-func-migration"
},
"dependencies": {
"@axinom/mosaic-db-common": "0.35.0",
"@axinom/mosaic-graphql-common": "0.11.0",
"@axinom/mosaic-id-guard": "0.30.0",
"@axinom/mosaic-messages": "0.41.0",
"@axinom/mosaic-message-bus": "0.25.0",
"@axinom/mosaic-message-bus-abstractions": "0.12.0",
"@axinom/mosaic-service-common": "0.47.0",
"@axinom/mosaic-transactional-inbox-outbox": "0.7.0",
"@axinom/mosaic-db-common": "0.36.0",
"@axinom/mosaic-graphql-common": "0.12.0",
"@axinom/mosaic-id-guard": "0.31.0",
"@axinom/mosaic-messages": "0.42.0",
"@axinom/mosaic-message-bus": "0.26.0",
"@axinom/mosaic-message-bus-abstractions": "0.13.0",
"@axinom/mosaic-service-common": "0.48.0",
"@axinom/mosaic-transactional-inbox-outbox": "0.8.1",
"@graphile-contrib/pg-simplify-inflector": "^6.1.0",
"add": "^2.0.6",
"amqplib": "^0.6.0",
Expand Down
16 changes: 8 additions & 8 deletions services/entitlement/service/package.json
Original file line number Diff line number Diff line change
Expand Up @@ -46,14 +46,14 @@
"util:define-func-migration": "yarn mosaic generate-define-func-migration"
},
"dependencies": {
"@axinom/mosaic-db-common": "0.35.0",
"@axinom/mosaic-graphql-common": "0.11.0",
"@axinom/mosaic-id-guard": "0.30.0",
"@axinom/mosaic-id-utils": "0.15.15",
"@axinom/mosaic-message-bus": "0.25.0",
"@axinom/mosaic-messages": "0.41.0",
"@axinom/mosaic-service-common": "0.47.0",
"@axinom/mosaic-transactional-inbox-outbox": "0.7.0",
"@axinom/mosaic-db-common": "0.36.0",
"@axinom/mosaic-graphql-common": "0.12.0",
"@axinom/mosaic-id-guard": "0.31.0",
"@axinom/mosaic-id-utils": "0.15.16",
"@axinom/mosaic-message-bus": "0.26.0",
"@axinom/mosaic-messages": "0.42.0",
"@axinom/mosaic-service-common": "0.48.0",
"@axinom/mosaic-transactional-inbox-outbox": "0.8.1",
"ajv": "^7.2.4",
"ajv-formats": "^1.6.1",
"@graphile-contrib/pg-simplify-inflector": "^6.1.0",
Expand Down
18 changes: 9 additions & 9 deletions services/media/service/package.json
Original file line number Diff line number Diff line change
Expand Up @@ -46,15 +46,15 @@
"util:define-func-migration": "yarn mosaic generate-define-func-migration"
},
"dependencies": {
"@axinom/mosaic-db-common": "0.35.0",
"@axinom/mosaic-graphql-common": "0.11.0",
"@axinom/mosaic-id-guard": "0.30.0",
"@axinom/mosaic-id-link-be": "0.19.0",
"@axinom/mosaic-message-bus": "0.25.0",
"@axinom/mosaic-message-bus-abstractions": "0.12.0",
"@axinom/mosaic-messages": "0.41.0",
"@axinom/mosaic-service-common": "0.47.0",
"@axinom/mosaic-transactional-inbox-outbox": "0.7.0",
"@axinom/mosaic-db-common": "0.36.0",
"@axinom/mosaic-graphql-common": "0.12.0",
"@axinom/mosaic-id-guard": "0.31.0",
"@axinom/mosaic-id-link-be": "0.20.0",
"@axinom/mosaic-message-bus": "0.26.0",
"@axinom/mosaic-message-bus-abstractions": "0.13.0",
"@axinom/mosaic-messages": "0.42.0",
"@axinom/mosaic-service-common": "0.48.0",
"@axinom/mosaic-transactional-inbox-outbox": "0.8.1",
"@faker-js/faker": "^7.6.0",
"@graphile-contrib/pg-simplify-inflector": "^6.1.0",
"ajv": "^7.2.4",
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -92,11 +92,11 @@ export class LocalizableCollectionImageDeletedDbMessageHandler extends Localizab
{
payload: { image_type, collection_id },
}: TypedTransactionalMessage<LocalizableCollectionImageDbEvent>,
loginClient: ClientBase,
ownerClient: ClientBase,
): Promise<LocalizationMessageData | undefined> {
if (
image_type !== 'COVER' ||
(await this.collectionIsDeleted(collection_id, loginClient))
(await this.collectionIsDeleted(collection_id, ownerClient))
) {
// Ignore any changes to non-cover image relations
// If image relation is deleted as part of a cascade delete of collection - no need to upsert
Expand All @@ -115,13 +115,13 @@ export class LocalizableCollectionImageDeletedDbMessageHandler extends Localizab

async collectionIsDeleted(
collectionId: number,
loginClient: ClientBase,
ownerClient: ClientBase,
): Promise<boolean> {
const data = await selectOne(
'collections',
{ id: collectionId },
{ columns: ['id'] },
).run(loginClient);
).run(ownerClient);
return !data;
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -78,7 +78,7 @@ describe('Start Ingest Item Handler', () => {
};

// Act
await ctx.executeGqlSql(user, async (dbCtx) =>
await ctx.executeOwnerSql(user, async (dbCtx) =>
handler.handleMessage(createMessage(payload), dbCtx),
);

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -38,11 +38,11 @@ export class DeleteEntityHandler extends MediaGuardedTransactionalInboxMessageHa

override async handleMessage(
{ payload, metadata }: TypedTransactionalMessage<DeleteEntityCommand>,
loginClient: ClientBase,
ownerClient: ClientBase,
): Promise<void> {
const deletedItems = await deletes(payload.table_name as Table, {
[payload.primary_key_name]: payload.entity_id,
}).run(loginClient);
}).run(ownerClient);

if (deletedItems.length >= 1) {
const deletedRow = deletedItems[0];
Expand All @@ -57,7 +57,7 @@ export class DeleteEntityHandler extends MediaGuardedTransactionalInboxMessageHa
primary_key_name: payload.primary_key_name,
table_name: payload.table_name,
},
loginClient,
ownerClient,
{ envelopeOverrides: { auth_token: metadata.authToken } },
);
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -29,14 +29,14 @@ export abstract class LocalizableMediaTransactionalInboxMessageHandler<

abstract getLocalizationCommandData(
message: TypedTransactionalMessage<T>,
loginClient: ClientBase,
ownerClient: ClientBase,
): Promise<LocalizationMessageData | undefined>;

override async handleMessage(
message: TypedTransactionalMessage<T>,
loginClient: ClientBase,
ownerClient: ClientBase,
): Promise<void> {
const data = await this.getLocalizationCommandData(message, loginClient);
const data = await this.getLocalizationCommandData(message, ownerClient);
if (!data) {
return;
}
Expand All @@ -46,7 +46,7 @@ export abstract class LocalizableMediaTransactionalInboxMessageHandler<
data.payload.entity_id,
data.settings,
data.payload,
loginClient,
ownerClient,
{
envelopeOverrides: {
auth_token: accessToken,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -54,7 +54,7 @@ describe('IngestMovieProcessor', () => {
};

// Act
const result = await ctx.executeGqlSql(user, async (dbCtx) => {
const result = await ctx.executeOwnerSql(user, async (dbCtx) => {
return processor.initializeMedia([item], dbCtx);
});

Expand Down Expand Up @@ -102,7 +102,7 @@ describe('IngestMovieProcessor', () => {
};

// Act
const result = await ctx.executeGqlSql(user, async (dbCtx) => {
const result = await ctx.executeOwnerSql(user, async (dbCtx) => {
return processor.initializeMedia([item], dbCtx);
});

Expand Down Expand Up @@ -148,7 +148,7 @@ describe('IngestMovieProcessor', () => {
];

// Act
const result = await ctx.executeGqlSql(user, async (dbCtx) => {
const result = await ctx.executeOwnerSql(user, async (dbCtx) => {
return processor.initializeMedia(items, dbCtx);
});

Expand Down Expand Up @@ -211,7 +211,7 @@ describe('IngestMovieProcessor', () => {

// Act
const error = await rejectionOf(
ctx.executeGqlSql(user, async (dbCtx) => {
ctx.executeOwnerSql(user, async (dbCtx) => {
return processor.initializeMedia(items, dbCtx);
}),
);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -41,7 +41,7 @@ describe('IngestMovieProcessor', () => {
describe('processImage', () => {
it('new cover image -> image relation created', async () => {
// Act
await ctx.executeGqlSql(user, async (dbCtx) => {
await ctx.executeOwnerSql(user, async (dbCtx) => {
await processor.processImage(movie1.id, imageId, 'COVER', dbCtx);
});

Expand All @@ -68,7 +68,7 @@ describe('IngestMovieProcessor', () => {
}).run(ctx.ownerPool);

// Act
await ctx.executeGqlSql(user, async (dbCtx) => {
await ctx.executeOwnerSql(user, async (dbCtx) => {
await processor.processImage(movie1.id, imageId, 'TEASER', dbCtx);
});

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -132,7 +132,7 @@ describe('IngestMovieProcessor', () => {
};

// Act
await ctx.executeGqlSql(user, async (dbCtx) => {
await ctx.executeOwnerSql(user, async (dbCtx) => {
await processor.processVideo(movie1.id, newId, messageContext, dbCtx);
});

Expand Down Expand Up @@ -177,7 +177,7 @@ describe('IngestMovieProcessor', () => {
};

// Act
await ctx.executeGqlSql(user, async (dbCtx) => {
await ctx.executeOwnerSql(user, async (dbCtx) => {
await processor.processVideo(movie1.id, newId, messageContext, dbCtx);
});

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -96,7 +96,7 @@ describe('IngestMovieProcessor', () => {
).run(ctx.ownerPool);

// Act
await ctx.executeGqlSql(user, async (dbCtx) => {
await ctx.executeOwnerSql(user, async (dbCtx) => {
await processor.updateMetadata(body, dbCtx, ingestItemId);
});

Expand Down Expand Up @@ -158,7 +158,7 @@ describe('IngestMovieProcessor', () => {
).run(ctx.ownerPool);

// Act
await ctx.executeGqlSql(user, async (dbCtx) => {
await ctx.executeOwnerSql(user, async (dbCtx) => {
await processor.updateMetadata(body, dbCtx);
});

Expand Down Expand Up @@ -210,7 +210,7 @@ describe('IngestMovieProcessor', () => {
const body = createMessageBody(movie1, data);

// Act
await ctx.executeGqlSql(user, async (dbCtx) => {
await ctx.executeOwnerSql(user, async (dbCtx) => {
await processor.updateMetadata(body, dbCtx);
});

Expand Down Expand Up @@ -262,7 +262,7 @@ describe('IngestMovieProcessor', () => {

// Act
const error = await rejectionOf(
ctx.executeGqlSql(user, async (dbCtx) => {
ctx.executeOwnerSql(user, async (dbCtx) => {
await processor.updateMetadata(body, dbCtx);
}),
);
Expand Down Expand Up @@ -295,7 +295,7 @@ describe('IngestMovieProcessor', () => {

// Act
const error = await rejectionOf(
ctx.executeGqlSql(user, async (dbCtx) => {
ctx.executeOwnerSql(user, async (dbCtx) => {
await processor.updateMetadata(body, dbCtx);
}),
);
Expand Down Expand Up @@ -348,7 +348,7 @@ describe('IngestMovieProcessor', () => {
const body = createMessageBody(movie1, data);

// Act
await ctx.executeGqlSql(user, async (dbCtx) => {
await ctx.executeOwnerSql(user, async (dbCtx) => {
await processor.updateMetadata(body, dbCtx);
});

Expand Down Expand Up @@ -387,7 +387,7 @@ describe('IngestMovieProcessor', () => {
const body = createMessageBody(movie1, data);

// Act
await ctx.executeGqlSql(user, async (dbCtx) => {
await ctx.executeOwnerSql(user, async (dbCtx) => {
await processor.updateMetadata(body, dbCtx);
});

Expand Down Expand Up @@ -425,7 +425,7 @@ describe('IngestMovieProcessor', () => {
const body = createMessageBody(movie1, data);

// Act
await ctx.executeGqlSql(user, async (dbCtx) => {
await ctx.executeOwnerSql(user, async (dbCtx) => {
await processor.updateMetadata(body, dbCtx);
});

Expand Down Expand Up @@ -486,7 +486,7 @@ describe('IngestMovieProcessor', () => {
const body = createMessageBody(movie1, data);

// Act
await ctx.executeGqlSql(user, async (dbCtx) => {
await ctx.executeOwnerSql(user, async (dbCtx) => {
await processor.updateMetadata(body, dbCtx);
});

Expand Down Expand Up @@ -548,7 +548,7 @@ describe('IngestMovieProcessor', () => {
});

// Act
await ctx.executeGqlSql(user, async (dbCtx) => {
await ctx.executeOwnerSql(user, async (dbCtx) => {
await processor.updateMetadata(body, dbCtx);
});

Expand Down Expand Up @@ -637,7 +637,7 @@ describe('IngestMovieProcessor', () => {
});

// Act
await ctx.executeGqlSql(user, async (dbCtx) => {
await ctx.executeOwnerSql(user, async (dbCtx) => {
await processor.updateMetadata(body, dbCtx);
});

Expand Down Expand Up @@ -698,7 +698,7 @@ describe('IngestMovieProcessor', () => {
});

// Act
await ctx.executeGqlSql(user, async (dbCtx) => {
await ctx.executeOwnerSql(user, async (dbCtx) => {
await processor.updateMetadata(body, dbCtx);
});

Expand Down
Loading

0 comments on commit 31b988d

Please sign in to comment.