cristiano.hoshikawa/agent_platform_oci
1
2
Fork 0
mirror of https://github.com/hoshikawa2/agent_platform_oci.git synced 2026-09-07 18:23:46 +00:00
Code Issues Packages Projects Releases Wiki Activity

Problema no sequence do pubsub. Precisa ser por transaction_id somente

Browse Source
This commit is contained in:
Cristiano Hoshikawa
2026-08-04 16:50:08 -03:00
parent 09b975b510
commit 3fd468fb92
1 changed files with 10 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
libs/agent_framework/src/agent_framework/analytics/tim_sequence.py
View File

@@ -106,17 +106,19 @@ def build_sequence_key(
session_id: str | None, session_id: str | None,
transaction_id: str | None = None, transaction_id: str | None = None,
) -> str: ) -> str:
"""Build the counter key, preferring transaction isolation. """Build the counter key, preferring transaction-only isolation.
``session_id`` remains as a compatibility fallback for older producers that ``session_id`` remains as a compatibility fallback for older producers that
do not yet send ``transactionId``. New events must use one counter per do not yet send ``transactionId``. New events must use one counter per
transaction so concurrent requests in the same session do not share a transaction so concurrent requests in the same session do not share a
sequence. sequence. The agent is deliberately omitted from transaction-scoped keys:
one transaction can emit GRL, AGA, IC and NOC events through different
framework components/agents, and all of them must share the same counter.
""" """
agent = _safe_part(agent_id or os.getenv("AGENT_NAME"), "agent")
if transaction_id: if transaction_id:
transaction = _safe_part(transaction_id, "unknown_transaction") transaction = _safe_part(transaction_id, "unknown_transaction")
return f"{_key_prefix()}:{agent}:transaction:{transaction}" return f"{_key_prefix()}:transaction:{transaction}"
agent = _safe_part(agent_id or os.getenv("AGENT_NAME"), "agent")
session = _safe_part(session_id, "unknown_session") session = _safe_part(session_id, "unknown_session")
return f"{_key_prefix()}:{agent}:session:{session}" return f"{_key_prefix()}:{agent}:session:{session}"
@@ -265,10 +267,10 @@ async def next_sequence(
) -> int | None: ) -> int | None:
"""Return the next observer sequence isolated by transaction. """Return the next observer sequence isolated by transaction.
The preferred scope is ``agent_id + transaction_id``. ``session_id`` is The preferred scope is ``transaction_id`` only. ``agent_id + session_id``
used only as a backward-compatible fallback when the producer does not send is used only as a backward-compatible fallback when the producer does not
a transaction identifier. Redis and MongoDB increments remain atomic across send a transaction identifier. Redis and MongoDB increments remain atomic
Kubernetes replicas. across Kubernetes replicas.
""" """
if not sequence_enabled() or (not transaction_id and not session_id): if not sequence_enabled() or (not transaction_id and not session_id):
return None return None