0878303a498477bc68274ae0e08f6d9613f929fe,core/eolearn/tests/test_eoexecutor.py,TestEOExecutor,test_execution_stats,#TestEOExecutor#,43

Before Change

            self.assertEqual(len(executor.execution_logs), 2)

    def test_execution_stats(self):
        task = ExampleTask()

        workflow = EOWorkflow(dependencies=[
            Dependency(task=task, inputs=[]),
        ])

        execution_args = [
            {"arg1": 1},
            {"arg1": 2}

After Change

            executor.run(workers=2)

            self.assertEqual(len(executor.execution_stats), 4)
            for stats in executor.execution_stats:
                for time_stat in ["start_time", "end_time"]:
                    self.assertTrue(time_stat in stats and isinstance(stats[time_stat], datetime.datetime))

    def test_execution_errors(self):
        with tempfile.TemporaryDirectory() as tmp_dir_name:
            executor = EOExecutor(self.workflow, self.execution_args, file_path=tmp_dir_name)
            executor.run(workers=5)

Instances