mirror of https://github.com/citusdata/citus.git
Fix rebase conflict
parent
ab345ab4fb
commit
ffd7dcc88f
|
@ -1953,6 +1953,8 @@ FindOrCreateWorkerPool(DistributedExecution *execution, char *nodeName, int node
|
||||||
dlist_init(&workerPool->pendingTaskQueue);
|
dlist_init(&workerPool->pendingTaskQueue);
|
||||||
dlist_init(&workerPool->readyTaskQueue);
|
dlist_init(&workerPool->readyTaskQueue);
|
||||||
|
|
||||||
|
workerPool->distributedExecution = execution;
|
||||||
|
|
||||||
execution->workerList = lappend(execution->workerList, workerPool);
|
execution->workerList = lappend(execution->workerList, workerPool);
|
||||||
|
|
||||||
return workerPool;
|
return workerPool;
|
||||||
|
|
Loading…
Reference in New Issue