fix(core/platform): platform event and adapters updates

This commit is contained in:
LIghtJUNction
2026-03-22 19:08:59 +08:00
parent 8cff9be334
commit dd5105a504
3 changed files with 4 additions and 4 deletions

View File

@@ -262,7 +262,7 @@ class AstrMessageEvent(abc.ABC):
目前仅支持: telegram,qq official 私聊。
Fallback仅支持 aiocqhttp。
"""
asyncio.create_task(
asyncio.create_task( # noqa: RUF006 # noqa: RUF006
Metric.upload(msg_event_tick=1, adapter_name=self.platform_meta.name),
)
self._has_send_oper = True
@@ -443,7 +443,7 @@ class AstrMessageEvent(abc.ABC):
# Leverage BLAKE2 hash function to generate a non-reversible hash of the sender ID for privacy.
hash_obj = hashlib.blake2b(self.get_sender_id().encode("utf-8"), digest_size=16)
sid = str(uuid.UUID(bytes=hash_obj.digest()))
asyncio.create_task(
asyncio.create_task( # noqa: RUF006
Metric.upload(
msg_event_tick=1,
adapter_name=self.platform_meta.name,

View File

@@ -62,7 +62,7 @@ class LarkPlatformAdapter(Platform):
await self.convert_msg(event)
def do_v2_msg_event(event: lark.im.v1.P2ImMessageReceiveV1) -> None:
asyncio.create_task(on_msg_event_recv(event))
asyncio.create_task(on_msg_event_recv(event)) # noqa: RUF006
self.event_handler = (
lark.EventDispatcherHandler.builder("", "")

View File

@@ -521,7 +521,7 @@ class TelegramPlatformEvent(AstrMessageEvent):
)
# 内联父类 send_streaming 的副作用(避免传入已消费的 generator)
asyncio.create_task(
asyncio.create_task( # noqa: RUF006
Metric.upload(msg_event_tick=1, adapter_name=self.platform_meta.name),
)
self._has_send_oper = True