---
 PVE/ReplicationState.pm | 10 +++++++++-
 1 file changed, 9 insertions(+), 1 deletion(-)

diff --git a/PVE/ReplicationState.pm b/PVE/ReplicationState.pm
index 0851195..52688bb 100644
--- a/PVE/ReplicationState.pm
+++ b/PVE/ReplicationState.pm
@@ -255,7 +255,15 @@ sub job_status {
        my $target = $jobcfg->{target};
        if (!$jobcfg->{remove_job}) {
            # never sync to local node
-           next if $target eq $local_node;
+           # but check if vm was stolen (swaped source target)
+           if ($target eq $local_node) {
+               my $source = $jobcfg->{source};
+               if (defined($source) && $source ne $target) {
+                   $jobcfg = 
PVE::ReplicationConfig::swap_source_target($jobid);
+               } else {
+                   next;
+               }
+           }
 
            next if !$get_disabled && $jobcfg->{disable};
        }
-- 
2.11.0


_______________________________________________
pve-devel mailing list
pve-devel@pve.proxmox.com
https://pve.proxmox.com/cgi-bin/mailman/listinfo/pve-devel

Reply via email to