Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
Cosmetics [ci-skip].
authorArnaud Giersch <arnaud.giersch@univ-fcomte.fr>
Mon, 14 Mar 2022 16:17:12 +0000 (17:17 +0100)
committerArnaud Giersch <arnaud.giersch@univ-fcomte.fr>
Mon, 14 Mar 2022 16:17:12 +0000 (17:17 +0100)
examples/python/comm-waitallfor/comm-waitallfor.py

index 207b327..b7d0342 100644 (file)
@@ -14,9 +14,9 @@ This example implements the following scenario:
 
 from argparse import ArgumentParser
 from dataclasses import dataclass
+from typing import List;
 from uuid import uuid4
 import sys
-import typing
 
 from simgrid import Actor, Comm, Engine, Host, Mailbox, PyGetAsync, this_actor
 
@@ -25,7 +25,7 @@ SIMULATED_JOB_SIZE_BYTES = 1024
 SIMULATED_RESULT_SIZE_BYTES = 1024 * 1024
 
 
-def parse_requests(requests_str: str) -> typing.List[float]:
+def parse_requests(requests_str: str) -> List[float]:
     return [float(item.strip()) for item in requests_str.split(",")]
 
 
@@ -89,7 +89,7 @@ class AsyncJobResult:
         return "complete" if self.complete else "pending"
 
 
-def client(client_id: str, jobs: typing.List[float], wait_timeout: float):
+def client(client_id: str, jobs: List[float], wait_timeout: float):
     worker_mailbox: Mailbox = Mailbox.by_name("worker")
     this_actor.info(f"{client_id} started")
     async_job_results: list[AsyncJobResult] = []