Private Deliverable Memo Content

examples/acp_base/cross_chain_transfer_service/buyer.py

@@ -69,7 +69,7 @@ def on_new_task(job: ACPJob, memo_to_sign: Optional[ACPMemo] = None):
             logger.info(f"Job {job.id} rejection memo signed")
 
         elif job.phase == ACPJobPhase.COMPLETED:
-            logger.info(f"Job {job.id} completed, received deliverable: {job.deliverable}")
+            logger.info(f"Job {job.id} completed, received deliverable: {job.get_deliverable()}")
 
         elif job.phase == ACPJobPhase.REJECTED:
             logger.info(f"Job {job.id} rejected by seller")

examples/acp_base/funds_transfer/prediction_market/buyer.py

@@ -59,7 +59,7 @@ def on_new_task(job: ACPJob, memo_to_sign: Optional[ACPMemo] = None):
                 msg = (
                         f"[on_new_task] Job {job_id} {job_phase}. "
                         + (
-                            f"Deliverable received: {job.deliverable}"
+                            f"Deliverable received: {job.get_deliverable()}"
                             if job_phase == ACPJobPhase.COMPLETED
                             else f"Rejection reason: {job.rejection_reason}"
                         )

examples/acp_base/funds_transfer/trading/buyer.py

@@ -59,7 +59,7 @@ def on_new_task(job: ACPJob, memo_to_sign: Optional[ACPMemo] = None):
                 msg = (
                     f"[on_new_task] Job {job_id} {job.phase}. "
                     + (
-                        f"Deliverable received: {job.deliverable}"
+                        f"Deliverable received: {job.get_deliverable()}"
                         if job.phase == ACPJobPhase.COMPLETED
                         else f"Rejection reason: {job.rejection_reason}"
                     )

examples/acp_base/polling_mode/buyer.py

@@ -34,7 +34,7 @@ def buyer():
             config=BASE_MAINNET_ACP_X402_CONFIG_V2,  # route to x402 for payment, undefined defaulted back to direct transfer
         ),
     )
-    logger.info(f"Buyer ACP Initialized. Agent: {acp_client.agent_address}")
+    logger.info(f"Buyer ACP Initialized. Agent: {acp_client.wallet_address}")
 
     # Browse available agents based on a keyword and cluster name
     relevant_agents = acp_client.browse_agents(

examples/acp_base/polling_mode/evaluator.py

@@ -36,11 +36,11 @@ def evaluator():
             entity_id=env.EVALUATOR_ENTITY_ID,
         ),
     )
-    logger.info(f"Evaluator ACP Initialized. Agent: {acp_client.agent_address}")
+    logger.info(f"Evaluator ACP Initialized. Agent: {acp_client.wallet_address}")
 
     while True:
         logger.info(
-            f"\nPolling for jobs assigned to {acp_client.agent_address} requiring evaluation."
+            f"\nPolling for jobs assigned to {acp_client.wallet_address} requiring evaluation."
         )
         active_jobs_list: List[ACPJob] = acp_client.get_active_jobs()
 
@@ -54,13 +54,13 @@ def evaluator():
             try:
 
                 # Ensure this job is for the current evaluator
-                if job.evaluator_address != acp_client.agent_address:
+                if job.evaluator_address != acp_client.wallet_address:
                     continue
 
                 if job.phase == ACPJobPhase.EVALUATION:
                     logger.info(f"Found Job {job.id} in EVALUATION phase.")
                     logger.info(
-                        f"Job {job.id}: Evaluating deliverable: {job.deliverable} with requirement: {job.requirement}"
+                        f"Job {job.id}: Evaluating deliverable: {job.get_deliverable()} with requirement: {job.requirement}"
                     )
                     job.evaluate(
                         accept=ACCEPT_EVALUATION,

examples/acp_base/polling_mode/seller.py

@@ -40,7 +40,7 @@ def seller():
 
     while True:
         logger.info(
-            f"\nPolling for active jobs for {acp_client.agent_address}."
+            f"\nPolling for active jobs for {acp_client.wallet_address}."
         )
         active_jobs_list: List[ACPJob] = acp_client.get_active_jobs()
 
@@ -51,7 +51,7 @@ def seller():
 
         for job in active_jobs_list:
             # Ensure this job is for the current seller
-            if job.provider_address != acp_client.agent_address:
+            if job.provider_address != acp_client.wallet_address:
                 continue
 
             try:

examples/acp_base/skip_evaluation/buyer.py

@@ -50,7 +50,7 @@ def on_new_task(job: ACPJob, memo_to_sign: Optional[ACPMemo] = None):
             logger.info(f"Job {job.id} rejection memo signed")
 
         elif job.phase == ACPJobPhase.COMPLETED:
-            logger.info(f"Job {job.id} completed, received deliverable: {job.deliverable}")
+            logger.info(f"Job {job.id} completed, received deliverable: {job.get_deliverable()}")
 
         elif job.phase == ACPJobPhase.REJECTED:
             logger.info(f"Job {job.id} rejected by seller")