def map()

in lambdamap/core.py [0:0]

• 20 lines of code
• 7 McCabe index (conditional complexity)

    def map(self, func, payloads, local_mode=False):
        """
        """
        
        from tqdm.autonotebook import tqdm
        
        if local_mode:
            f = func
        else:
            f = LambdaFunction(func, self._client, self._lambda_arn)
        
        ex = self._executor
        wait_for = [ex.submit(f, *p["args"], **p["kwargs"]) for p in payloads]
        tbar = tqdm(total=len(wait_for))
        prev_n_done = 0
        n_done = sum(f.done() for f in wait_for)
        
        while n_done != len(wait_for):
            tbar.update(n_done - prev_n_done)
            prev_n_done = n_done
            n_done = sum(f.done() for f in wait_for)
            time.sleep(0.5)
            
        tbar.update(n_done - prev_n_done)   
        tbar.close()
            
        results = [f.result() for f in futures.as_completed(wait_for)]
        return results