Skip to content

Commit d426fe6

Browse files
committed
reove changes from internal_only
1 parent 133bc09 commit d426fe6

1 file changed

Lines changed: 2 additions & 4 deletions

File tree

src/aggregate/aggregate_debug.c

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -105,6 +105,7 @@ int parseAndCompileDebug(AREQ_Debug *debug_req, QueryError *status) {
105105
PipelineAddCrash(&debug_req->r);
106106
}
107107

108+
108109
// Handle timeout
109110
if (AC_IsInitialized(&timeoutArgs)) {
110111
unsigned long long results_count = -1;
@@ -140,11 +141,8 @@ int parseAndCompileDebug(AREQ_Debug *debug_req, QueryError *status) {
140141
// If it is set - if we are in a cluster coordinator - do nothing
141142
// If it is not set - if we are not cluster coordinator - do nothing
142143
// This can be checked by comparing isClusterCoord(debug_req) and internal_only
143-
// #####
144-
// ##### TO DO REVERT FIX MOVE TO Another PR!!!
145-
// #######
146144
if ((debug_req->r.reqflags & QEXEC_F_IS_AGGREGATE) &&
147-
isClusterCoord(debug_req) && internal_only) {
145+
isClusterCoord(debug_req) == internal_only) {
148146
return REDISMODULE_OK;
149147
}
150148

0 commit comments

Comments
 (0)