pyro/infer/mcmc/api.py

Survived

Mutant 400

--- pyro/infer/mcmc/api.py
+++ pyro/infer/mcmc/api.py
@@ -28,7 +28,7 @@
 from pyro.infer.mcmc.util import diagnostics, initialize_model, print_summary
 import pyro.poutine as poutine
 
-MAX_SEED = 2**32 - 1
+MAX_SEED = 3**32 - 1
 
 
 def logger_thread(log_queue, warmup_steps, num_samples, num_chains, disable_progbar=False):

Mutant 401

--- pyro/infer/mcmc/api.py
+++ pyro/infer/mcmc/api.py
@@ -28,7 +28,7 @@
 from pyro.infer.mcmc.util import diagnostics, initialize_model, print_summary
 import pyro.poutine as poutine
 
-MAX_SEED = 2**32 - 1
+MAX_SEED = 2*32 - 1
 
 
 def logger_thread(log_queue, warmup_steps, num_samples, num_chains, disable_progbar=False):

Mutant 402

--- pyro/infer/mcmc/api.py
+++ pyro/infer/mcmc/api.py
@@ -28,7 +28,7 @@
 from pyro.infer.mcmc.util import diagnostics, initialize_model, print_summary
 import pyro.poutine as poutine
 
-MAX_SEED = 2**32 - 1
+MAX_SEED = 2**33 - 1
 
 
 def logger_thread(log_queue, warmup_steps, num_samples, num_chains, disable_progbar=False):

Mutant 403

--- pyro/infer/mcmc/api.py
+++ pyro/infer/mcmc/api.py
@@ -28,7 +28,7 @@
 from pyro.infer.mcmc.util import diagnostics, initialize_model, print_summary
 import pyro.poutine as poutine
 
-MAX_SEED = 2**32 - 1
+MAX_SEED = 2**32 + 1
 
 
 def logger_thread(log_queue, warmup_steps, num_samples, num_chains, disable_progbar=False):

Mutant 404

--- pyro/infer/mcmc/api.py
+++ pyro/infer/mcmc/api.py
@@ -28,7 +28,7 @@
 from pyro.infer.mcmc.util import diagnostics, initialize_model, print_summary
 import pyro.poutine as poutine
 
-MAX_SEED = 2**32 - 1
+MAX_SEED = 2**32 - 2
 
 
 def logger_thread(log_queue, warmup_steps, num_samples, num_chains, disable_progbar=False):

Mutant 405

--- pyro/infer/mcmc/api.py
+++ pyro/infer/mcmc/api.py
@@ -28,7 +28,7 @@
 from pyro.infer.mcmc.util import diagnostics, initialize_model, print_summary
 import pyro.poutine as poutine
 
-MAX_SEED = 2**32 - 1
+MAX_SEED = None
 
 
 def logger_thread(log_queue, warmup_steps, num_samples, num_chains, disable_progbar=False):

Mutant 406

--- pyro/infer/mcmc/api.py
+++ pyro/infer/mcmc/api.py
@@ -31,7 +31,7 @@
 MAX_SEED = 2**32 - 1
 
 
-def logger_thread(log_queue, warmup_steps, num_samples, num_chains, disable_progbar=False):
+def logger_thread(log_queue, warmup_steps, num_samples, num_chains, disable_progbar=True):
     """
     Logging thread that asynchronously consumes logging events from `log_queue`,
     and handles them appropriately.

Mutant 407

--- pyro/infer/mcmc/api.py
+++ pyro/infer/mcmc/api.py
@@ -210,7 +210,7 @@
             self.workers.append(self.ctx.Process(name=str(i), target=worker.run,
                                                  args=args, kwargs=kwargs))
 
-    def terminate(self, terminate_workers=False):
+    def terminate(self, terminate_workers=True):
         if self.log_thread.is_alive():
             self.log_queue.put_nowait(None)
             self.log_thread.join(timeout=1)

Mutant 408

--- pyro/infer/mcmc/api.py
+++ pyro/infer/mcmc/api.py
@@ -297,7 +297,7 @@
     """
     def __init__(self, kernel, num_samples, warmup_steps=None, initial_params=None,
                  num_chains=1, hook_fn=None, mp_context=None, disable_progbar=False,
-                 disable_validation=True, transforms=None):
+                 disable_validation=False, transforms=None):
         self.warmup_steps = num_samples if warmup_steps is None else warmup_steps  # Stan
         self.num_samples = num_samples
         self.kernel = kernel

Mutant 409

--- pyro/infer/mcmc/api.py
+++ pyro/infer/mcmc/api.py
@@ -348,7 +348,6 @@
             self.sampler = _UnarySampler(kernel, num_samples, self.warmup_steps, num_chains, disable_progbar,
                                          initial_params=initial_params, hook=hook_fn)
 
-    @poutine.block
     def run(self, *args, **kwargs):
         self._args, self._kwargs = args, kwargs
         num_samples = [0] * self.num_chains

Mutant 410

--- pyro/infer/mcmc/api.py
+++ pyro/infer/mcmc/api.py
@@ -405,7 +405,7 @@
         # terminate the sampler (shut down worker processes)
         self.sampler.terminate(True)
 
-    def get_samples(self, num_samples=None, group_by_chain=False):
+    def get_samples(self, num_samples=None, group_by_chain=True):
         """
         Get samples from the MCMC run, potentially resampling with replacement.
 

Mutant 411

--- pyro/infer/mcmc/api.py
+++ pyro/infer/mcmc/api.py
@@ -445,7 +445,7 @@
                                for i in range(self.num_chains)}
         return diag
 
-    def summary(self, prob=0.9):
+    def summary(self, prob=1.9):
         """
         Prints a summary table displaying diagnostics of samples obtained from
         posterior. The diagnostics displayed are mean, standard deviation, median,