Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 3 additions & 3 deletions src/biz_layer/mem_memorize.py
Original file line number Diff line number Diff line change
Expand Up @@ -1290,7 +1290,7 @@ async def memorize(request: MemorizeRequest) -> int:
# ===== Preprocess and get historical data =====
if request.raw_data_type == RawDataType.CONVERSATION:
request = await preprocess_conv_request(request, current_time)
if request == None:
if request is None:
logger.warning(f"[mem_memorize] preprocess_conv_request returned None")
return 0

Expand Down Expand Up @@ -1326,7 +1326,7 @@ async def memorize(request: MemorizeRequest) -> int:
)
logger.debug(f"[mem_memorize] Extracting MemCell took: {time.perf_counter() - memcell_start} seconds")

if memcell_result == None:
if memcell_result is None:
logger.warning(f"[mem_memorize] Skipped extracting MemCell")
return 0

Expand All @@ -1345,7 +1345,7 @@ async def memorize(request: MemorizeRequest) -> int:
)
logger.info("=" * 80)

if memcell == None:
if memcell is None:
# No boundary detected, confirm current messages to accumulation (sync_status: -1 -> 0)
await conversation_data_repo.save_conversation_data(
request.new_raw_data_list, request.group_id
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -56,7 +56,7 @@ async def ensure_latest(
).update_many({"$set": {"is_latest": False}})

# Update the latest version's is_latest to True
if latest_version.is_latest != True:
if latest_version.is_latest is not True:
latest_version.is_latest = True
await latest_version.save(session=session)
logger.debug(
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -59,7 +59,7 @@ async def ensure_latest(
).update_many({"$set": {"is_latest": False}})

# Update the latest version's is_latest to True
if latest_version.is_latest != True:
if latest_version.is_latest is not True:
latest_version.is_latest = True
await latest_version.save(session=session)
logger.debug(
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -83,7 +83,7 @@ async def ensure_latest(
).update_many({"$set": {"is_latest": False}})

# Update the latest version's is_latest to True
if latest_version.is_latest != True:
if latest_version.is_latest is not True:
latest_version.is_latest = True
await latest_version.save(session=session)
logger.debug(
Expand Down