fix(test): fix syntax errors on windows.
This commit is contained in:
parent
f6fea32eeb
commit
fc218a1f69
|
@ -103,8 +103,11 @@ void setTask(SStreamTask* pTask, int32_t nodeId, int64_t streamId, int32_t taskI
|
||||||
pTask->id.taskId = taskId;
|
pTask->id.taskId = taskId;
|
||||||
pTask->info.nodeId = nodeId;
|
pTask->info.nodeId = nodeId;
|
||||||
|
|
||||||
STaskId id = {.streamId = pTask->id.streamId, .taskId = pTask->id.taskId};
|
STaskId id;
|
||||||
STaskStatusEntry entry = {0};
|
id.streamId = pTask->id.streamId;
|
||||||
|
id.taskId = pTask->id.taskId;
|
||||||
|
|
||||||
|
STaskStatusEntry entry;
|
||||||
streamTaskStatusInit(&entry, pTask);
|
streamTaskStatusInit(&entry, pTask);
|
||||||
|
|
||||||
entry.stage = 1;
|
entry.stage = 1;
|
||||||
|
|
Loading…
Reference in New Issue