From ed5decfd6c3b1c67d2fae14466b060bbc4b29891 Mon Sep 17 00:00:00 2001
From: Matthieu Baerts <matttbe@kernel.org>
Date: Tue, 11 Aug 2026 19:42:40 +0200
Subject: [PATCH] fetchers: add marker at the end of the test

This imitates what is done by the poller node: when this marker is
written, the uploader service knows it can stop monitoring the current
directory. This avoids having too many inotify instances which can cause
troubles.

All users of "Fetcher" are using the same pattern: a log message and the
creation of the result dir at the beginning, and a log message at the
end (except for exec and gh, added here). Now, an empty '.tester_done'
file is created at the end as well.

Note that some of these fetchers don't seem to be used any more.

Signed-off-by: Matthieu Baerts <matttbe@kernel.org>
---
 contest/hw/hwksft.py       | 1 +
 contest/remote/exec.py     | 3 +++
 contest/remote/gh.py       | 3 +++
 contest/remote/kunit.py    | 1 +
 contest/remote/vmksft-p.py | 1 +
 contest/remote/vmksft.py   | 1 +
 contest/remote/vmtest.py   | 1 +
 7 files changed, 11 insertions(+)

diff --git a/contest/hw/hwksft.py b/contest/hw/hwksft.py
index 281810c4..87da7637 100644
--- a/contest/hw/hwksft.py
+++ b/contest/hw/hwksft.py
@@ -369,6 +369,7 @@ def test(binfo, rinfo, cbarg):  # pylint: disable=unused-argument
         except Exception as e:
             print(f"Warning: failed to close reservation {reservation_id}: {e}")
 
+    os.mknod(os.path.join(results_path, ".tester_done"))
     print("Done at", datetime.datetime.now())
     if cases is None:
         cases = [{
diff --git a/contest/remote/exec.py b/contest/remote/exec.py
index 47454e11..5aef25f3 100755
--- a/contest/remote/exec.py
+++ b/contest/remote/exec.py
@@ -76,6 +76,9 @@ def test(binfo, rinfo, config):
            config.get('local', 'results_path') + '/' + \
            rinfo['run-cookie']
 
+    os.mknod(os.path.join(results_path, ".tester_done"))
+    print("Done at", datetime.datetime.now())
+
     return [{'test': config.get('executor', 'test'),
              'group': config.get('executor', 'group'),
              'result': res, 'link': link}]
diff --git a/contest/remote/gh.py b/contest/remote/gh.py
index 6db9f3ee..a70d45d6 100755
--- a/contest/remote/gh.py
+++ b/contest/remote/gh.py
@@ -219,6 +219,9 @@ def test(binfo, rinfo, cbarg):
                 one['retry'] = one2['result']
                 break
 
+    os.mknod(os.path.join(results_path, ".tester_done"))
+    print("Done at", datetime.datetime.now())
+
     return res
 
 
diff --git a/contest/remote/kunit.py b/contest/remote/kunit.py
index bdfa2fde..f0105fe0 100755
--- a/contest/remote/kunit.py
+++ b/contest/remote/kunit.py
@@ -194,6 +194,7 @@ def test(binfo, rinfo, config):
                   'group': config.get('executor', 'group'),
                   'result': 'fail', 'link': link}]
 
+    os.mknod(os.path.join(results_path, ".tester_done"))
     print("Done at", datetime.datetime.now())
 
     return cases
diff --git a/contest/remote/vmksft-p.py b/contest/remote/vmksft-p.py
index 1aeaaa96..c605652e 100755
--- a/contest/remote/vmksft-p.py
+++ b/contest/remote/vmksft-p.py
@@ -317,6 +317,7 @@ def test(binfo, rinfo, cbarg):
     if not in_queue.empty():
         print("ERROR: in queue is not empty")
 
+    os.mknod(os.path.join(results_path, ".tester_done"))
     print("Done at", datetime.datetime.now())
 
     return cases
diff --git a/contest/remote/vmksft.py b/contest/remote/vmksft.py
index a738f0fc..2fc0b661 100755
--- a/contest/remote/vmksft.py
+++ b/contest/remote/vmksft.py
@@ -221,6 +221,7 @@ def test(binfo, rinfo, cbarg):
     vm.stop()
     vm.dump_log(results_path + '/vm-stop')
 
+    os.mknod(os.path.join(results_path, ".tester_done"))
     print("Done at", datetime.datetime.now())
 
     return cases
diff --git a/contest/remote/vmtest.py b/contest/remote/vmtest.py
index a2ca5b14..7d0dc5a6 100755
--- a/contest/remote/vmtest.py
+++ b/contest/remote/vmtest.py
@@ -129,6 +129,7 @@ def test(binfo, rinfo, cbarg):
     vm.stop()
     vm.dump_log(results_path + '/vm-stop-' + str(vm_id))
 
+    os.mknod(os.path.join(results_path, ".tester_done"))
     print("Done at", datetime.datetime.now())
 
     return cases