Changeset 3739629 for veloimg/trunk/src/Queue/Worker.php

Timestamp:

10/11/2026 02:52:48 PM (5 weeks ago)

Author:

enetrato

Message:

Release VeloIMG 0.9.7

File:

• veloimg/trunk/src/Queue/Worker.php (modified) (3 diffs)

veloimg/trunk/src/Queue/Worker.php

@@ -6 +6 @@
 
 use VeloWP\Converter\Processor;
+use VeloWP\Conversion\WebpRetry;
 use VeloWP\Concurrency\LeaseLostException;
 use VeloWP\Core\Checker;
@@ -181 +182 @@
                         $files_repo = new FilesRepository();
                         $proc     = new Processor( $store, $mapper, $files_repo, (array) ( $report['caps'] ?? array() ), $settings, array( 'assert_ownership' => static function () use ( $token ) : void { Lock::assert_owned( $token ); } ) );
+                        $retry_proc = null;
 
                         foreach ( $pending as $task ) {
@@ -243 +245 @@
                                 }
 
-                                $res = $proc->generate_from_rel( $orig, false );
+                                // Generic ticks may also process automatic uploads. Only rows owned by
+                                // this exact retry run receive its immutable settings, including after Resume.
+                                $task_proc = $proc;
+                                if ( '' !== $task_run_id && $task_run_id === (string) ( $mass_activation['run_id'] ?? '' ) && ! empty( $mass_activation['retry'] ) ) {
+                                        if ( null === $retry_proc ) {
+                                                $retry = (array) $mass_activation['retry'];
+                                                $retry_proc = new Processor( $store, $mapper, $files_repo, WebpRetry::caps( (array) ( $report['caps'] ?? array() ), $retry ), WebpRetry::settings( $settings, $retry ), array( 'assert_ownership' => static function () use ( $token ) : void { Lock::assert_owned( $token ); } ) );
+                                        }
+                                        $task_proc = $retry_proc;
+                                }
+                                $res = $task_proc->generate_from_rel( $orig, false );
                                 Lock::assert_owned( $token );
                                 if ( empty( $res['ok'] ) ) {