X-Git-Url: https://git.donarmstrong.com/?a=blobdiff_plain;f=dak%2Fprocess_new.py;h=9f9a39cf2154e4465dddb688798778721c7f235e;hb=55513d80673e99884067b8820ca1a0b3e9aeeeef;hp=f33b53bace1e1d570ef544baaf72c2013335d375;hpb=1d7f6d35706b847dd00bec1d8694f8676ec215a8;p=dak.git diff --git a/dak/process_new.py b/dak/process_new.py index f33b53ba..9f9a39cf 100755 --- a/dak/process_new.py +++ b/dak/process_new.py @@ -54,6 +54,7 @@ import pwd import apt_pkg, apt_inst import examine_package import subprocess +import daklib.daksubprocess from sqlalchemy import or_ from daklib.dbconn import * @@ -346,8 +347,11 @@ def check_pkg (upload, upload_copy, session): suite_name = upload.target_suite.suite_name handler = PolicyQueueUploadHandler(upload, session) missing = [(m['type'], m["package"]) for m in handler.missing_overrides(hints=missing)] + + less_cmd = ("less", "-R", "-") + less_process = daklib.daksubprocess.Popen(less_cmd, bufsize=0, stdin=subprocess.PIPE) try: - sys.stdout = os.popen("less -R -", 'w', 0) + sys.stdout = less_process.stdin print examine_package.display_changes(suite_name, changes) source = upload.source @@ -364,6 +368,7 @@ def check_pkg (upload, upload_copy, session): print examined print examine_package.output_package_relations() + less_process.stdin.close() except IOError as e: if e.errno == errno.EPIPE: utils.warn("[examine_package] Caught EPIPE; skipping.") @@ -372,6 +377,7 @@ def check_pkg (upload, upload_copy, session): except KeyboardInterrupt: utils.warn("[examine_package] Caught C-c; skipping.") finally: + less_process.wait() sys.stdout = save_stdout ################################################################################ @@ -449,7 +455,7 @@ def run_user_inspect_command(upload, upload_copy): changes=changes, ) - subprocess.check_call(shell_command, shell=True) + daklib.daksubprocess.check_call(shell_command, shell=True) ################################################################################