diff --git a/src/biz_layer/mem_memorize.py b/src/biz_layer/mem_memorize.py index e951a13c..89b4902a 100644 --- a/src/biz_layer/mem_memorize.py +++ b/src/biz_layer/mem_memorize.py @@ -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 @@ -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 @@ -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 diff --git a/src/infra_layer/adapters/out/persistence/repository/core_memory_raw_repository.py b/src/infra_layer/adapters/out/persistence/repository/core_memory_raw_repository.py index 8c532d48..3998ea0d 100644 --- a/src/infra_layer/adapters/out/persistence/repository/core_memory_raw_repository.py +++ b/src/infra_layer/adapters/out/persistence/repository/core_memory_raw_repository.py @@ -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( diff --git a/src/infra_layer/adapters/out/persistence/repository/group_profile_raw_repository.py b/src/infra_layer/adapters/out/persistence/repository/group_profile_raw_repository.py index 0935bb94..4d16a01c 100644 --- a/src/infra_layer/adapters/out/persistence/repository/group_profile_raw_repository.py +++ b/src/infra_layer/adapters/out/persistence/repository/group_profile_raw_repository.py @@ -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( diff --git a/src/infra_layer/adapters/out/persistence/repository/group_user_profile_memory_raw_repository.py b/src/infra_layer/adapters/out/persistence/repository/group_user_profile_memory_raw_repository.py index f0bfbbdf..094a4165 100644 --- a/src/infra_layer/adapters/out/persistence/repository/group_user_profile_memory_raw_repository.py +++ b/src/infra_layer/adapters/out/persistence/repository/group_user_profile_memory_raw_repository.py @@ -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(