db connection context fix (#4453)
fixing use of the wrong connection context inside a task
This commit is contained in:
@@ -729,7 +729,7 @@ export class PostgresStorageAdapter {
|
|||||||
const values = [className, ...valuesArray];
|
const values = [className, ...valuesArray];
|
||||||
return conn.task(t => {
|
return conn.task(t => {
|
||||||
return this._ensureSchemaCollectionExists(t)
|
return this._ensureSchemaCollectionExists(t)
|
||||||
.then(() => conn.none(qs, values))
|
.then(() => t.none(qs, values))
|
||||||
.catch(error => {
|
.catch(error => {
|
||||||
if (error.code === PostgresDuplicateRelationError) {
|
if (error.code === PostgresDuplicateRelationError) {
|
||||||
// Table already exists, must have been created by a different request. Ignore error.
|
// Table already exists, must have been created by a different request. Ignore error.
|
||||||
|
|||||||
Reference in New Issue
Block a user