anonfunc/alhp
Archived
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

don't update while worker processes are running

Browse Source
This commit is contained in:
Giovanni Harting
2021-05-18 21:14:31 +02:00
parent eec49d74d7
commit af5e766b06
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
master.py
View File

@@ -210,7 +210,7 @@ def update_git2svn():
stderr=subprocess.STDOUT).stdout.decode()) stderr=subprocess.STDOUT).stdout.decode())
else: else:
os.chdir(git_dir) os.chdir(git_dir)
logging.debug("[GIT] %s", subprocess.run(["git", "clean", "-xdf"], check=True, stdout=subprocess.PIPE, logging.debug("[GIT] %s", subprocess.run(["git", "clean", "-xdf"], check=False, stdout=subprocess.PIPE,
stderr=subprocess.STDOUT).stdout.decode()) stderr=subprocess.STDOUT).stdout.decode())
logging.debug("[GIT] %s", subprocess.run(["git", "reset", "--hard"], check=True, stdout=subprocess.PIPE, logging.debug("[GIT] %s", subprocess.run(["git", "reset", "--hard"], check=True, stdout=subprocess.PIPE,
stderr=subprocess.STDOUT).stdout.decode()) stderr=subprocess.STDOUT).stdout.decode())
@@ -346,7 +346,7 @@ if __name__ == '__main__':
while True: while True:
try: try:
if time.time() - update_last > 900: if time.time() - update_last > 900 and q.qsize() == 0:
update_last = time.time() update_last = time.time()
update_git2svn() update_git2svn()
fill_queue() fill_queue()