Merge pull request #1265 from JosepSampe/lithops-dev

[Standalone] Do not stop the VM immediately after a job in the Consume mode

CHANGELOG.md

@@ -7,14 +7,15 @@
 - [Stats] Added new CPU, Memory and Network statistics in the function results
 - [IBM VPC] Added a new parameter to enable/disable resource existence check in the platform
 
-
 ### Changed
 - [Config] Renamed 'customized_runtime' to 'runtime_include_function'
-- [IBM VPC] Increase the total number of available IPs in the private network
+- [IBM VPC] Increased the total number of available IPs in the private network
+- [Standalone] Do not stop the VM immediately after a job in the Cosume mode
 
 ### Fixed
 - [Standalone] Fixed issue that appears when the invocation payload is too big
 - [Invoker] Fixed "runtime_include_function" function/modules path
+- [AWS EC2] Reset the public IP address of the master VM on stop
 
 
 ## [v3.1.1]

lithops/standalone/backends/aws_ec2/aws_ec2.py

@@ -918,8 +918,7 @@ def dismantle(self, include_master=True):
                 ex.map(lambda worker: worker.stop(), self.workers)
             self.workers = []
 
-        if include_master or self.mode == StandaloneMode.CONSUME.value:
-            # in consume mode master VM is a worker
+        if include_master:
             self.master.stop()
 
     def get_instance(self, name, **kwargs):

lithops/standalone/backends/azure_vms/azure_vms.py

@@ -591,8 +591,7 @@ def dismantle(self, include_master=True):
                 ex.map(lambda worker: worker.stop(), self.workers)
             self.workers = []
 
-        if include_master or self.mode == StandaloneMode.CONSUME.value:
-            # in consume mode master VM is a worker
+        if include_master:
             self.master.stop()
 
     def get_instance(self, name, **kwargs):

lithops/standalone/backends/ibm_vpc/ibm_vpc.py

@@ -811,8 +811,7 @@ def dismantle(self, include_master=True):
                 ex.map(lambda worker: worker.stop(), self.workers)
             self.workers = []
 
-        if include_master or self.mode == StandaloneMode.CONSUME.value:
-            # in consume mode master VM is a worker
+        if include_master:
             self.master.stop()
 
     def get_instance(self, name, **kwargs):