feat: allow for timeouts on tasks

packages/packages.json

@@ -2,12 +2,12 @@
     "dev": {
         "connection/valory/websocket_client/0.1.0": "bafybeicz53kzs5uvyiod2azntl76zwgmpgr22ven4wl5fnwt2m546j3wsu",
         "skill/valory/contract_subscription/0.1.0": "bafybeif3hkpgbzuoxsbqxnd752qkvk3onytltrufnyrphnqbi62si4mdhy",
-        "agent/valory/mech/0.1.0": "bafybeicybguqpwjrpwye3trclcyxt4ca43k4nyrzm2c2zcvbyf5gnokl4u",
-        "skill/valory/multiplexer_abci/0.1.0": "bafybeibjvmrz5r3qgynkpuawwzwmesc5ozmnvs4xykbybo6zno7qpaqg4m",
-        "skill/valory/task_execution_abci/0.1.0": "bafybeifd6ubbhqp6xa3vg6mpimw555j7rn2d7n4jybfmwhoqqi4ql2fu2m",
-        "skill/valory/mech_abci/0.1.0": "bafybeiglgiiyy5kqf3rdaelw47f3hsw2tpihowayjjzmagoiixd6t6dzvy",
+        "agent/valory/mech/0.1.0": "bafybeid5twhl7ofc6th6ecnvvogccqupckzdgj44huylmezn6uh5va7sf4",
+        "skill/valory/multiplexer_abci/0.1.0": "bafybeiabjge5xdlvdox4rauhb255v2b3idfzpbhgrfl46njnbcuisr5c6i",
+        "skill/valory/task_execution_abci/0.1.0": "bafybeig2gtvcfatqymkjhlmtv4iaisdqfq3nwv2p7vkvwmoxlgrvl4t6oa",
+        "skill/valory/mech_abci/0.1.0": "bafybeighsclgvvuwqnvnthwrpory6qdiju2sjhi5jqx7scwtjzro7afevy",
         "contract/valory/agent_mech/0.1.0": "bafybeiasgzwum4kypi5d4ubldvj7ihg6tyvpnvt5gyqbx3jdsku7b3gxgy",
-        "service/valory/mech/0.1.0": "bafybeibtkfvqb3tcnakqbzlfb5xnfsmnvnicms7bgvl5x5ramscfqzwsue",
+        "service/valory/mech/0.1.0": "bafybeihyjqsmp4o22hj5dulqwwtigioyljiimmwbnh5xcsgjfuktulwemi",
         "protocol/valory/acn_data_share/0.1.0": "bafybeieyixetwvz767zekhvg7r6etumyanzys6xbalx2brrfswybinnlhi",
         "protocol/valory/default/1.0.0": "bafybeiecmut3235aen7wxukllv424f3dysvvlgfmn562kzdunc5hdj3hxu"
     },
@@ -20,20 +20,20 @@
         "protocol/valory/acn/1.1.0": "bafybeiapa5ilsobggnspoqhspftwolrx52udrwmaxdxgrk26heuvl4oooa",
         "protocol/valory/ipfs/0.1.0": "bafybeibjzhsengtxfofqpxy6syamplevp35obemwfp4c5lhag3v2bvgysa",
         "protocol/valory/tendermint/0.1.0": "bafybeidjqmwvgi4rqgp65tbkhmi45fwn2odr5ecezw6q47hwitsgyw4jpa",
-        "skill/valory/abstract_abci/0.1.0": "bafybeih3bwx5apteinnoxts7sqmjlskntdbo7vvnmdbs5noo2pv76by7fu",
-        "skill/valory/reset_pause_abci/0.1.0": "bafybeigzvwbzktclahjbsyiwqnj6poree4iveon5pric6s5ixb6wrhkdhq",
-        "skill/valory/registration_abci/0.1.0": "bafybeia25gpusnkakb2dp4heqkwtuftbc2apppq3i4bds6sphltsovgzvi",
-        "skill/valory/abstract_round_abci/0.1.0": "bafybeibqpzbklnljvtc67yon4ciijxj75d7vazm7rurcvbbfnk6jtudukm",
-        "contract/valory/service_registry/0.1.0": "bafybeidjm7w7pugc6kzrxlhbtnnc4rpgr3pkrg3owdxacrccar5qqwyu2e",
-        "connection/valory/abci/0.1.0": "bafybeic6beo7cpd2qtotntlbmsrs3qfn7fw5eh2vkav6milat6awao46pu",
+        "skill/valory/abstract_abci/0.1.0": "bafybeiamr3cwetayz6lr72buhq6iviabtboj4hhpq47tlumimxolvvqjcy",
+        "skill/valory/reset_pause_abci/0.1.0": "bafybeialcwck7fahrr23jckv5qjwg3cdq4ai2ihyjsofnbj44jzyl4cjmm",
+        "skill/valory/registration_abci/0.1.0": "bafybeibafy7qmcvvzaykimy3mbqdwtcuajmbghqilaa7zwkh6wla33cfce",
+        "skill/valory/abstract_round_abci/0.1.0": "bafybeiaseziuvbzh3trjggl5hx2tv3fduqrpiwiyksudaf6nvuxmwrg74i",
+        "contract/valory/service_registry/0.1.0": "bafybeiae7nr5fqn6ckt3ehol27qfd4o5ljzx6kk5k32lgtrvj3mtb62ufm",
+        "connection/valory/abci/0.1.0": "bafybeig6difzdar2n5gya7cq2xa7c2rxxp65xlxviatqzg33kivvc3zaam",
         "connection/valory/http_client/0.23.0": "bafybeieoeuy4brzimtnubmokwirhrx27ezls6cdnl5qik4rkykfle3nn2y",
         "connection/valory/ipfs/0.1.0": "bafybeicwe4fksbhaqs4qycfdqbzgqtikfn3u4g5y5fucxfmriezwwf7hse",
         "connection/valory/ledger/0.19.0": "bafybeiejc7g7ebv3cleiqb4f4h4pspcu6vtr54332szwlqiabfs3sfdh44",
         "connection/valory/p2p_libp2p_client/0.1.0": "bafybeihdnfdth3qgltefgrem7xyi4b3ejzaz67xglm2hbma2rfvpl2annq",
-        "contract/valory/gnosis_safe_proxy_factory/0.1.0": "bafybeiesdz7xfijeomjpps3e5k3zspvisx2xje6yqub6hzj4uczr7q33wq",
-        "contract/valory/gnosis_safe/0.1.0": "bafybeibhezhwgi5ustv675gfohsq5l5xjijp36gqueuicyl2ofrtkrortm",
-        "skill/valory/transaction_settlement_abci/0.1.0": "bafybeiepus7qsa47gt7dyk32gaqsoae6whjoxfnplttulxrvmcauyerrdm",
+        "contract/valory/gnosis_safe_proxy_factory/0.1.0": "bafybeigbtbgzqlt4tufgymtjsyxiqvivxmtc4csx43hmo5nexmdfcxm6bi",
+        "contract/valory/gnosis_safe/0.1.0": "bafybeic3ajabs7sl6qgkzy452szlsdeitj746kdzfd7k4m4ixtxw4g33qi",
+        "skill/valory/transaction_settlement_abci/0.1.0": "bafybeiacwr7p4nhhufoey7uz2jqkegrlykdrmc7mm3rzkvh2mslu66gyle",
         "contract/valory/multisend/0.1.0": "bafybeict2k3vf3c4fvzosaq5kku2ivtzsskbomrujmmoicut7eg52onnje",
-        "skill/valory/termination_abci/0.1.0": "bafybeibcdgnarxyyqexncpfewcemraryywtwueuv7qthsjuean5l77lp2e"
+        "skill/valory/termination_abci/0.1.0": "bafybeifqsogqiar4yook5bu3j6z66dbdcizey7dr3e5oxeocdjijvfbaja"
     }
 }

packages/valory/agents/mech/aea-config.yaml

@@ -7,18 +7,18 @@ aea_version: '>=1.37.0, <2.0.0'
 fingerprint: {}
 fingerprint_ignore_patterns: []
 connections:
-- valory/abci:0.1.0:bafybeic6beo7cpd2qtotntlbmsrs3qfn7fw5eh2vkav6milat6awao46pu
+- valory/abci:0.1.0:bafybeig6difzdar2n5gya7cq2xa7c2rxxp65xlxviatqzg33kivvc3zaam
 - valory/http_client:0.23.0:bafybeieoeuy4brzimtnubmokwirhrx27ezls6cdnl5qik4rkykfle3nn2y
 - valory/ipfs:0.1.0:bafybeicwe4fksbhaqs4qycfdqbzgqtikfn3u4g5y5fucxfmriezwwf7hse
 - valory/ledger:0.19.0:bafybeiejc7g7ebv3cleiqb4f4h4pspcu6vtr54332szwlqiabfs3sfdh44
 - valory/p2p_libp2p_client:0.1.0:bafybeihdnfdth3qgltefgrem7xyi4b3ejzaz67xglm2hbma2rfvpl2annq
 - valory/websocket_client:0.1.0:bafybeicz53kzs5uvyiod2azntl76zwgmpgr22ven4wl5fnwt2m546j3wsu
 contracts:
 - valory/agent_mech:0.1.0:bafybeiasgzwum4kypi5d4ubldvj7ihg6tyvpnvt5gyqbx3jdsku7b3gxgy
-- valory/gnosis_safe:0.1.0:bafybeibhezhwgi5ustv675gfohsq5l5xjijp36gqueuicyl2ofrtkrortm
-- valory/gnosis_safe_proxy_factory:0.1.0:bafybeiesdz7xfijeomjpps3e5k3zspvisx2xje6yqub6hzj4uczr7q33wq
+- valory/gnosis_safe:0.1.0:bafybeic3ajabs7sl6qgkzy452szlsdeitj746kdzfd7k4m4ixtxw4g33qi
+- valory/gnosis_safe_proxy_factory:0.1.0:bafybeigbtbgzqlt4tufgymtjsyxiqvivxmtc4csx43hmo5nexmdfcxm6bi
 - valory/multisend:0.1.0:bafybeict2k3vf3c4fvzosaq5kku2ivtzsskbomrujmmoicut7eg52onnje
-- valory/service_registry:0.1.0:bafybeidjm7w7pugc6kzrxlhbtnnc4rpgr3pkrg3owdxacrccar5qqwyu2e
+- valory/service_registry:0.1.0:bafybeiae7nr5fqn6ckt3ehol27qfd4o5ljzx6kk5k32lgtrvj3mtb62ufm
 protocols:
 - valory/default:1.0.0:bafybeiecmut3235aen7wxukllv424f3dysvvlgfmn562kzdunc5hdj3hxu
 - open_aea/signing:1.0.0:bafybeifuxs7gdg2okbn7uofymenjlmnih2wxwkym44lsgwmklgwuckxm2m
@@ -31,16 +31,16 @@ protocols:
 - valory/tendermint:0.1.0:bafybeidjqmwvgi4rqgp65tbkhmi45fwn2odr5ecezw6q47hwitsgyw4jpa
 - valory/acn_data_share:0.1.0:bafybeieyixetwvz767zekhvg7r6etumyanzys6xbalx2brrfswybinnlhi
 skills:
-- valory/abstract_abci:0.1.0:bafybeih3bwx5apteinnoxts7sqmjlskntdbo7vvnmdbs5noo2pv76by7fu
-- valory/abstract_round_abci:0.1.0:bafybeibqpzbklnljvtc67yon4ciijxj75d7vazm7rurcvbbfnk6jtudukm
+- valory/abstract_abci:0.1.0:bafybeiamr3cwetayz6lr72buhq6iviabtboj4hhpq47tlumimxolvvqjcy
+- valory/abstract_round_abci:0.1.0:bafybeiaseziuvbzh3trjggl5hx2tv3fduqrpiwiyksudaf6nvuxmwrg74i
 - valory/contract_subscription:0.1.0:bafybeif3hkpgbzuoxsbqxnd752qkvk3onytltrufnyrphnqbi62si4mdhy
-- valory/mech_abci:0.1.0:bafybeiglgiiyy5kqf3rdaelw47f3hsw2tpihowayjjzmagoiixd6t6dzvy
-- valory/multiplexer_abci:0.1.0:bafybeibjvmrz5r3qgynkpuawwzwmesc5ozmnvs4xykbybo6zno7qpaqg4m
-- valory/registration_abci:0.1.0:bafybeia25gpusnkakb2dp4heqkwtuftbc2apppq3i4bds6sphltsovgzvi
-- valory/reset_pause_abci:0.1.0:bafybeigzvwbzktclahjbsyiwqnj6poree4iveon5pric6s5ixb6wrhkdhq
-- valory/task_execution_abci:0.1.0:bafybeifd6ubbhqp6xa3vg6mpimw555j7rn2d7n4jybfmwhoqqi4ql2fu2m
-- valory/termination_abci:0.1.0:bafybeibcdgnarxyyqexncpfewcemraryywtwueuv7qthsjuean5l77lp2e
-- valory/transaction_settlement_abci:0.1.0:bafybeiepus7qsa47gt7dyk32gaqsoae6whjoxfnplttulxrvmcauyerrdm
+- valory/mech_abci:0.1.0:bafybeighsclgvvuwqnvnthwrpory6qdiju2sjhi5jqx7scwtjzro7afevy
+- valory/multiplexer_abci:0.1.0:bafybeiabjge5xdlvdox4rauhb255v2b3idfzpbhgrfl46njnbcuisr5c6i
+- valory/registration_abci:0.1.0:bafybeibafy7qmcvvzaykimy3mbqdwtcuajmbghqilaa7zwkh6wla33cfce
+- valory/reset_pause_abci:0.1.0:bafybeialcwck7fahrr23jckv5qjwg3cdq4ai2ihyjsofnbj44jzyl4cjmm
+- valory/task_execution_abci:0.1.0:bafybeig2gtvcfatqymkjhlmtv4iaisdqfq3nwv2p7vkvwmoxlgrvl4t6oa
+- valory/termination_abci:0.1.0:bafybeifqsogqiar4yook5bu3j6z66dbdcizey7dr3e5oxeocdjijvfbaja
+- valory/transaction_settlement_abci:0.1.0:bafybeiacwr7p4nhhufoey7uz2jqkegrlykdrmc7mm3rzkvh2mslu66gyle
 default_ledger: ethereum
 required_ledgers:
 - ethereum
@@ -145,6 +145,7 @@ models:
       on_chain_service_id: ${int:1}
       multisend_address: ${str:0xA238CBeb142c10Ef7Ad8442C6D1f9E89e07e7761}
       service_registry_address: ${str:0x9338b5153AE39BB89f50468E608eD9d764B755fD}
+      task_deadline: ${float:240.0}
       setup:
         all_participants: ${list:["0x10E867Ac2Fb0Aa156ca81eF440a5cdf373bE1AaC"]}
         safe_contract_address: ${str:0x5e1D1eb61E1164D5a50b28C575dA73A29595dFf7}

packages/valory/services/mech/service.yaml

@@ -7,7 +7,7 @@ license: Apache-2.0
 fingerprint:
   README.md: bafybeif7ia4jdlazy6745ke2k2x5yoqlwsgwr6sbztbgqtwvs3ndm2p7ba
 fingerprint_ignore_patterns: []
-agent: valory/mech:0.1.0:bafybeicybguqpwjrpwye3trclcyxt4ca43k4nyrzm2c2zcvbyf5gnokl4u
+agent: valory/mech:0.1.0:bafybeid5twhl7ofc6th6ecnvvogccqupckzdgj44huylmezn6uh5va7sf4
 number_of_agents: 4
 deployment:
   agent:
@@ -87,6 +87,7 @@ type: skill
         validate_timeout: 1205
         agent_mech_contract_address: ${AGENT_MECH_CONTRACT_ADDRESS:str:0xFf82123dFB52ab75C417195c5fDB87630145ae81}
         reset_period_count: ${RESET_PERIOD_COUNT:int:1000}
+        task_deadline: ${TASK_DEADLINE:int:240.0}
         file_hash_to_tools_json: ${FILE_HASH_TO_TOOLS:list:[]}
         api_keys_json: ${API_KEYS:list:[]}
 1:
@@ -124,6 +125,7 @@ type: skill
         polling_interval: ${POLLING_INTERVAL:int:25}
         tendermint_com_url: ${TENDERMINT_COM_URL:str:http://localhost:8080}
         tendermint_max_retries: 5
+        task_deadline: ${TASK_DEADLINE:int:240.0}
         tendermint_url: ${TENDERMINT_URL:str:http://localhost:26657}
         tendermint_p2p_url: ${TM_P2P_ENDPOINT_NODE_1:str:node0:26656}
         termination_sleep: ${TERMINATION_SLEEP:int:900}
@@ -157,6 +159,7 @@ type: skill
         retry_timeout: 3
         reset_pause_duration: ${RESET_PAUSE_DURATION:int:10}
         request_retry_delay: 1.0
+        task_deadline: ${TASK_DEADLINE:int:240.0}
         request_timeout: 10.0
         round_timeout_seconds: ${ROUND_TIMEOUT:float:150.0}
         service_id: mech
@@ -194,6 +197,7 @@ type: skill
         keeper_allowed_retries: 3
         keeper_timeout: 30.0
         max_attempts: 10
+        task_deadline: ${TASK_DEADLINE:int:240.0}
         max_healthcheck: 120
         multisend_address: ${MULTISEND_ADDRESS:str:0xA238CBeb142c10Ef7Ad8442C6D1f9E89e07e7761}
         on_chain_service_id: ${ON_CHAIN_SERVICE_ID:int:null}

packages/valory/skills/mech_abci/skill.yaml

@@ -18,13 +18,13 @@ connections: []
 contracts: []
 protocols: []
 skills:
-- valory/abstract_round_abci:0.1.0:bafybeibqpzbklnljvtc67yon4ciijxj75d7vazm7rurcvbbfnk6jtudukm
-- valory/multiplexer_abci:0.1.0:bafybeibjvmrz5r3qgynkpuawwzwmesc5ozmnvs4xykbybo6zno7qpaqg4m
-- valory/registration_abci:0.1.0:bafybeia25gpusnkakb2dp4heqkwtuftbc2apppq3i4bds6sphltsovgzvi
-- valory/reset_pause_abci:0.1.0:bafybeigzvwbzktclahjbsyiwqnj6poree4iveon5pric6s5ixb6wrhkdhq
-- valory/task_execution_abci:0.1.0:bafybeifd6ubbhqp6xa3vg6mpimw555j7rn2d7n4jybfmwhoqqi4ql2fu2m
-- valory/termination_abci:0.1.0:bafybeibcdgnarxyyqexncpfewcemraryywtwueuv7qthsjuean5l77lp2e
-- valory/transaction_settlement_abci:0.1.0:bafybeiepus7qsa47gt7dyk32gaqsoae6whjoxfnplttulxrvmcauyerrdm
+- valory/abstract_round_abci:0.1.0:bafybeiaseziuvbzh3trjggl5hx2tv3fduqrpiwiyksudaf6nvuxmwrg74i
+- valory/multiplexer_abci:0.1.0:bafybeiabjge5xdlvdox4rauhb255v2b3idfzpbhgrfl46njnbcuisr5c6i
+- valory/registration_abci:0.1.0:bafybeibafy7qmcvvzaykimy3mbqdwtcuajmbghqilaa7zwkh6wla33cfce
+- valory/reset_pause_abci:0.1.0:bafybeialcwck7fahrr23jckv5qjwg3cdq4ai2ihyjsofnbj44jzyl4cjmm
+- valory/task_execution_abci:0.1.0:bafybeig2gtvcfatqymkjhlmtv4iaisdqfq3nwv2p7vkvwmoxlgrvl4t6oa
+- valory/termination_abci:0.1.0:bafybeifqsogqiar4yook5bu3j6z66dbdcizey7dr3e5oxeocdjijvfbaja
+- valory/transaction_settlement_abci:0.1.0:bafybeiacwr7p4nhhufoey7uz2jqkegrlykdrmc7mm3rzkvh2mslu66gyle
 behaviours:
   main:
     args: {}
@@ -147,6 +147,7 @@ models:
       tendermint_url: http://localhost:26657
       termination_sleep: 900
       tx_timeout: 10.0
+      task_deadline: 240.0
       use_polling: false
       use_termination: false
       validate_timeout: 1205

packages/valory/skills/multiplexer_abci/skill.yaml

@@ -21,7 +21,7 @@ contracts:
 protocols:
 - valory/contract_api:1.0.0:bafybeiasywsvax45qmugus5kxogejj66c5taen27h4voriodz7rgushtqa
 skills:
-- valory/abstract_round_abci:0.1.0:bafybeibqpzbklnljvtc67yon4ciijxj75d7vazm7rurcvbbfnk6jtudukm
+- valory/abstract_round_abci:0.1.0:bafybeiaseziuvbzh3trjggl5hx2tv3fduqrpiwiyksudaf6nvuxmwrg74i
 behaviours:
   main:
     args: {}

packages/valory/skills/task_execution_abci/behaviours.py

@@ -19,6 +19,7 @@
 
 """This package contains round behaviours of TaskExecutionAbciApp."""
 import os
+import time
 from abc import ABC
 from multiprocessing.pool import AsyncResult
 from typing import Any, Dict, Generator, List, Optional, Set, Tuple, Type, cast
@@ -97,6 +98,8 @@ def __init__(self, **kwargs: Any) -> None:
         self.request_id = None
         self._is_task_prepared = False
         self._invalid_request = False
+        self._task_deadline: Optional[float] = None
+        self._processing_task: Optional[Dict[str, Any]] = None
 
     def _AsyncBehaviour__handle_waiting_for_message(self) -> None:
         """Handle an 'act' tick, when waiting for a message."""
@@ -134,9 +137,14 @@ def async_act(self) -> Generator:  # pylint: disable=R0914,R0915
             self.context.params.__dict__["_frozen"] = True
 
         with self.context.benchmark_tool.measure(self.behaviour_id).local():
-            task_result = yield from self.get_task_result()
-            if task_result is None:
-                # the task is not ready yet, check in the next iteration
+            try:
+                task_result = yield from self.get_task_result()
+                if task_result is None:
+                    # the task is not ready yet, check in the next iteration
+                    return
+            except TimeoutError:
+                # the task was not ready in time
+                self._handle_timeout()
                 return
             payload_content = yield from self.get_payload_content(task_result)
             sender = self.context.agent_address
@@ -193,6 +201,12 @@ def get_task_result(  # pylint: disable=R0914,R1710
             self.context.logger.info(f"Preparing task with data: {task_data}")
             self.request_id = task_data["requestId"]
             self.sender_address = task_data["sender"]
+            # store the task data so that we can
+            # add it to the end of the queue if needed
+            self._processing_task = task_data
+            # Set the deadline for the task
+            # it's okay to use time.time() here
+            self._task_deadline = time.time() + self.params.task_deadline
             task_data_ = task_data["data"]
 
             # Verify the data hash and handle encoding
@@ -252,6 +266,8 @@ def get_task_result(  # pylint: disable=R0914,R1710
         # Handle unfinished task
         if not self._invalid_request and not self._async_result.ready():
             self.context.logger.debug("The task is not finished yet.")
+            if time.time() > self._task_deadline:
+                raise TimeoutError("The task is not finished in the deadline.")
             yield from self.sleep(self.params.sleep_time)
             return None
 
@@ -463,6 +479,24 @@ def _get_deliver_tx(
             "data": data,
         }
 
+    def _handle_timeout(self) -> None:
+        """Handle a timeout."""
+        # append to the end of the queue
+        self.context.shared_state.get("pending_tasks").append(self._processing_task)
+        # reset the state
+        self._async_result: Optional[AsyncResult] = None
+        self.request_id = None
+        self._is_task_prepared = False
+        self._invalid_request = False
+        self._task_deadline: Optional[float] = None
+        self._processing_task: Optional[Dict[str, Any]] = None
+        self._task_deadline: Optional[float] = None
+        self._processing_task: Optional[Dict[str, Any]] = None
+        # wait for the round timeout s.t. the next task
+        # has a full round to be executed
+        yield from self.wait_until_round_end()
+        self.set_done()
+
 
 class TaskExecutionRoundBehaviour(AbstractRoundBehaviour):
     """TaskExecutionRoundBehaviour"""

packages/valory/skills/task_execution_abci/models.py

@@ -75,6 +75,7 @@ def __init__(self, *args: Any, **kwargs: Any) -> None:
         self.ipfs_fetch_timeout = self._ensure(
             "ipfs_fetch_timeout", kwargs=kwargs, type_=float
         )
+        self.task_deadline = self._ensure("task_deadline", kwargs=kwargs, type_=float)
         super().__init__(*args, **kwargs)
 
     def _nested_list_todict_workaround(

packages/valory/skills/task_execution_abci/skill.yaml

@@ -8,13 +8,13 @@ license: Apache-2.0
 aea_version: '>=1.0.0, <2.0.0'
 fingerprint:
   __init__.py: bafybeihrkpey6kxur2uoimrskq2wfpelqidxeapdxie6iuv2x7dk77ksvu
-  behaviours.py: bafybeihhddcm6qdavd5w4fshyknn3ukjmjpswwcdem6l4no62nqhbgqkda
+  behaviours.py: bafybeibtcg4wyfehuumjv4eqapkrfsklxfioczju425us2mibfnv4ls5we
   dialogues.py: bafybeibmac3m5u5h6ucoyjr4dazay72dyga656wvjl6z6saapluvjo54ne
   fsm_specification.yaml: bafybeia66ok2ll4kjbbmgbocjfape6u6ctacgexrnpgmru6zudr5em7vty
   handlers.py: bafybeibe5n7my2vd2wlwo73sbma65epjqc7kxgtittewlylcmvnmoxtxzq
   io_/__init__.py: bafybeifxgmmwjqzezzn3e6keh2bfo4cyo7y5dq2ept3stfmgglbrzfl5rq
   io_/naive_loader.py: bafybeihqrt34jso7dwfcedh7itmmovfv55tdjhw2tkqifsbiohetbonynu
-  models.py: bafybeihavofxq3nxt46x74idm2mjl5xxghoqzjtuxnx5i255k6mdwsyyaq
+  models.py: bafybeifc6emcgxezrhudosk3htpznssel6uml57gkqy6gyrh64efl2af24
   payloads.py: bafybeigptsnusjowmqjcxnzc4ct7n2iczuiorlwqsg7dl6ipnwkjb6iqoe
   rounds.py: bafybeifaza7nzpn7fv6xuk6pcamxne3b5tzqogricjkcvbek5cso2emcnm
   tasks.py: bafybeicu5t5cvfhbndgpxbbtmp4vbmtyb6fba6vsnlewftvuderxp5lwcy
@@ -23,14 +23,14 @@ connections:
 - valory/p2p_libp2p_client:0.1.0:bafybeihdnfdth3qgltefgrem7xyi4b3ejzaz67xglm2hbma2rfvpl2annq
 contracts:
 - valory/agent_mech:0.1.0:bafybeiasgzwum4kypi5d4ubldvj7ihg6tyvpnvt5gyqbx3jdsku7b3gxgy
-- valory/gnosis_safe:0.1.0:bafybeibhezhwgi5ustv675gfohsq5l5xjijp36gqueuicyl2ofrtkrortm
+- valory/gnosis_safe:0.1.0:bafybeic3ajabs7sl6qgkzy452szlsdeitj746kdzfd7k4m4ixtxw4g33qi
 - valory/multisend:0.1.0:bafybeict2k3vf3c4fvzosaq5kku2ivtzsskbomrujmmoicut7eg52onnje
 protocols:
 - valory/contract_api:1.0.0:bafybeiasywsvax45qmugus5kxogejj66c5taen27h4voriodz7rgushtqa
 - valory/acn_data_share:0.1.0:bafybeieyixetwvz767zekhvg7r6etumyanzys6xbalx2brrfswybinnlhi
 skills:
-- valory/abstract_round_abci:0.1.0:bafybeibqpzbklnljvtc67yon4ciijxj75d7vazm7rurcvbbfnk6jtudukm
-- valory/transaction_settlement_abci:0.1.0:bafybeiepus7qsa47gt7dyk32gaqsoae6whjoxfnplttulxrvmcauyerrdm
+- valory/abstract_round_abci:0.1.0:bafybeiaseziuvbzh3trjggl5hx2tv3fduqrpiwiyksudaf6nvuxmwrg74i
+- valory/transaction_settlement_abci:0.1.0:bafybeiacwr7p4nhhufoey7uz2jqkegrlykdrmc7mm3rzkvh2mslu66gyle
 behaviours:
   main:
     args: {}
@@ -143,6 +143,7 @@ models:
         safe_contract_address: '0x0000000000000000000000000000000000000000'
       share_tm_config_on_startup: false
       sleep_time: 1
+      task_deadline: 240.0
       tendermint_check_sleep_delay: 3
       tendermint_com_url: http://localhost:8080
       tendermint_max_retries: 5