diff options
| author | 2023-03-13 02:07:55 -0400 | |
|---|---|---|
| committer | 2023-03-13 02:07:55 -0400 | |
| commit | c5965a4d7650b7e935f630e40d883801967f7bcc (patch) | |
| tree | 2223d05254347c00a339e4476d3daea7b2624fb4 /gallery_dl/postprocessor/exec.py | |
| parent | baa8beeeb8bbe097f0b33d8c029fbd299253efa0 (diff) | |
| parent | 10987f08f8b6c510ba64f4b42d95ba67eec6e5b0 (diff) | |
Update upstream source from tag 'upstream/1.25.0'
Update to upstream version '1.25.0'
with Debian dir c2275e6e216e12115941d12f2b939d3f1a36436e
Diffstat (limited to 'gallery_dl/postprocessor/exec.py')
| -rw-r--r-- | gallery_dl/postprocessor/exec.py | 19 |
1 files changed, 18 insertions, 1 deletions
diff --git a/gallery_dl/postprocessor/exec.py b/gallery_dl/postprocessor/exec.py index cc217c3..e81c6cf 100644 --- a/gallery_dl/postprocessor/exec.py +++ b/gallery_dl/postprocessor/exec.py @@ -1,6 +1,6 @@ # -*- coding: utf-8 -*- -# Copyright 2018-2021 Mike Fährmann +# Copyright 2018-2023 Mike Fährmann # # This program is free software; you can redistribute it and/or modify # it under the terms of the GNU General Public License version 2 as @@ -43,11 +43,18 @@ class ExecPP(PostProcessor): events = events.split(",") job.register_hooks({event: execute for event in events}, options) + self._init_archive(job, options) + def exec_list(self, pathfmt, status=None): if status: return + archive = self.archive kwdict = pathfmt.kwdict + + if archive and archive.check(kwdict): + return + kwdict["_directory"] = pathfmt.realdirectory kwdict["_filename"] = pathfmt.filename kwdict["_path"] = pathfmt.realpath @@ -55,10 +62,17 @@ class ExecPP(PostProcessor): args = [arg.format_map(kwdict) for arg in self.args] self._exec(args, False) + if archive: + archive.add(kwdict) + def exec_string(self, pathfmt, status=None): if status: return + archive = self.archive + if archive and archive.check(pathfmt.kwdict): + return + if status is None and pathfmt.realpath: args = self.args.replace("{}", quote(pathfmt.realpath)) else: @@ -66,6 +80,9 @@ class ExecPP(PostProcessor): self._exec(args, True) + if archive: + archive.add(pathfmt.kwdict) + def _exec(self, args, shell): self.log.debug("Running '%s'", args) retcode = subprocess.Popen(args, shell=shell).wait() |
