bobseares-2/customer-integration-engineer
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

a2a-source-edit: write agent.py

Browse Source
This commit is contained in:
a2a-cloud
2026-07-13 03:41:06 +00:00
parent 17fd28d560
commit cd32841d19
1 changed files with 9 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
agent.py
View File

@@ -575,15 +575,20 @@ class CustomerIntegrationEngineer(A2AAgent[CustomerIntegrationEngineerConfig, No
else: else:
step_results.append(AcceptanceStepResult(name=test.name, status="skipped", attempts=0, detail="dry_run/default safe mode: endpoint metadata was validated but no DNS lookup or external request was sent", idempotency_key=idem)) step_results.append(AcceptanceStepResult(name=test.name, status="skipped", attempts=0, detail="dry_run/default safe mode: endpoint metadata was validated but no DNS lookup or external request was sent", idempotency_key=idem))
continue continue
validation = await _validate_endpoint_target(test.url, request.external_host_allowlist) metadata_validation = _validate_endpoint_metadata(test.url, request.external_host_allowlist)
if validation: if metadata_validation:
step_results.append(AcceptanceStepResult(name=test.name, status="blocked", attempts=0, detail=validation, idempotency_key=idem)) step_results.append(AcceptanceStepResult(name=test.name, status="blocked", attempts=0, detail=metadata_validation, idempotency_key=idem))
warnings.append(validation) warnings.append(metadata_validation)
continue continue
if live_network_block: if live_network_block:
step_results.append(AcceptanceStepResult(name=test.name, status="blocked", attempts=0, detail=live_network_block, idempotency_key=idem)) step_results.append(AcceptanceStepResult(name=test.name, status="blocked", attempts=0, detail=live_network_block, idempotency_key=idem))
warnings.append(live_network_block) warnings.append(live_network_block)
continue continue
validation = await _validate_endpoint_target(test.url, request.external_host_allowlist)
if validation:
step_results.append(AcceptanceStepResult(name=test.name, status="blocked", attempts=0, detail=validation, idempotency_key=idem))
warnings.append(validation)
continue
result = await _call_endpoint_with_retries(test, request.max_retries, request.timeout_seconds, idem) result = await _call_endpoint_with_retries(test, request.max_retries, request.timeout_seconds, idem)
network_calls += result.attempts network_calls += result.attempts
step_results.append(result) step_results.append(result)