def __init__(self, neo4j_client: Neo4jClient, max_workers: int = None): self.executor = ThreadPoolExecutor(max_workers=max_workers) super().__init__(neo4j_client)