From 535570ac0662dafb83b20c1235fd853ac9b40f6f Mon Sep 17 00:00:00 2001 From: Pascal Brokmeier Date: Thu, 4 Mar 2021 15:28:52 +0100 Subject: [PATCH] Add info logging to ThreadRunner (#706) MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit * add some logging to thread runner * Update kedro/runner/thread_runner.py Co-authored-by: Lorena Bălan * update release notes Co-authored-by: Lorena Bălan Co-authored-by: Zain Patel Co-authored-by: Merel Theisen <49397448+MerelTheisenQB@users.noreply.github.com> --- RELEASE.md | 5 +++-- kedro/runner/thread_runner.py | 4 ++++ 2 files changed, 7 insertions(+), 2 deletions(-) diff --git a/RELEASE.md b/RELEASE.md index 3c573f098c..7df54adf85 100644 --- a/RELEASE.md +++ b/RELEASE.md @@ -54,8 +54,9 @@ from kedro.framework.session import KedroSession [noklam](https://github.com/noklam), [Ivan Doroshenko](https://github.com/imdoroshenko), [Zain Patel](https://github.com/mzjp2), -[Deepyaman Datta](https://github.com/deepyaman) -[Sam Hiscox](https://github.com/samhiscoxqb) +[Deepyaman Datta](https://github.com/deepyaman), +[Sam Hiscox](https://github.com/samhiscoxqb), +[Pascal Brokmeier](https://github.com/pascalwhoop) ## Thanks for supporting contributions diff --git a/kedro/runner/thread_runner.py b/kedro/runner/thread_runner.py index 4f5d8741b5..3fd42c177e 100644 --- a/kedro/runner/thread_runner.py +++ b/kedro/runner/thread_runner.py @@ -147,6 +147,10 @@ def _run( # pylint: disable=too-many-locals,useless-suppression self._suggest_resume_scenario(pipeline, done_nodes) raise done_nodes.add(node) + self._logger.info("Completed node: %s", node.name) + self._logger.info( + "Completed %d out of %d tasks", len(done_nodes), len(nodes) + ) # decrement load counts and release any data sets we've finished # with this is particularly important for the shared datasets we