Update upstream source from tag 'upstream/1.30.8'

Update to upstream version '1.30.8'
with Debian dir 51367313d3355f7d0d16a754c5c63135fb3c72e2

1 files changed, 12 insertions, 8 deletions

diff --git a/gallery_dl/postprocessor/python.py b/gallery_dl/postprocessor/python.py
index db71da2..66d9343 100644
--- a/gallery_dl/postprocessor/python.py
+++ b/gallery_dl/postprocessor/python.py
@@ -1,6 +1,6 @@
 # -*- coding: utf-8 -*-
 
-# Copyright 2023 Mike Fährmann
+# Copyright 2023-2025 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
@@ -17,13 +17,14 @@ class PythonPP(PostProcessor):
     def __init__(self, job, options):
         PostProcessor.__init__(self, job)
 
-        spec = options["function"]
-        module_name, _, function_name = spec.rpartition(":")
-        module = util.import_file(module_name)
-        self.function = getattr(module, function_name)
-
-        if self._init_archive(job, options):
-            self.run = self.run_archive
+        mode = options.get("mode")
+        if mode == "eval" or not mode and options.get("expression"):
+            self.function = util.compile_expression(options["expression"])
+        else:
+            spec = options["function"]
+            module_name, _, function_name = spec.rpartition(":")
+            module = util.import_file(module_name)
+            self.function = getattr(module, function_name)
 
         events = options.get("event")
         if events is None:
@@ -32,6 +33,9 @@ class PythonPP(PostProcessor):
             events = events.split(",")
         job.register_hooks({event: self.run for event in events}, options)
 
+        if self._init_archive(job, options):
+            self.run = self.run_archive
+
     def run(self, pathfmt):
         self.function(pathfmt.kwdict)