We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 3075122 commit a88b09fCopy full SHA for a88b09f
src/scheduler/scheduler.ts
@@ -89,7 +89,6 @@ const resolveTable = async (
89
) => {
90
logger.info(`resolving table ${table.name}`);
91
const stream = new TableResolverStream();
92
- const resolverPromise = table.resolver(client, parent, stream);
93
94
const processData = async (data: unknown) => {
95
logger.debug(`resolving resource for table ${table.name}`);
@@ -163,6 +162,8 @@ const resolveTable = async (
163
162
await queue.add(() => processData(data));
164
});
165
+ const resolverPromise = table.resolver(client, parent, stream);
166
+
167
try {
168
await resolverPromise;
169
} catch (error) {
0 commit comments