fix(stream): remove invalid assert.

This commit is contained in:
Haojun Liao 2025-02-09 22:29:41 +08:00
parent 1c0a0443c5
commit 5f9ce8826d
1 changed files with 0 additions and 2 deletions

View File

@ -119,13 +119,11 @@ void streamQueueNextItemInSourceQ(SStreamQueue* pQueue, SStreamQueueItem** pItem
if (flag == STREAM_QUEUE__CHKPTFAILED) {
*pItem = pQueue->qChkptItem;
ASSERT(status != TASK_STATUS__CK && pQueue->qItem == NULL);
return;
}
if (flag == STREAM_QUEUE__FAILED) {
*pItem = pQueue->qItem;
ASSERT(status != TASK_STATUS__CK && pQueue->qChkptItem == NULL);
return;
}