

def assert_mock_cluster_is(self, mock_cluster, starting=False, bootstrapping=False, done=False, from_end_of_hour=timedelta(hours=1), has_pending_steps=False, idle_for=timedelta(0), pool_hash=None, pool_name=None, running=False, non_streaming=False):
    self.assertEqual(starting, _is_cluster_starting(mock_cluster))
    self.assertEqual(bootstrapping, _is_cluster_bootstrapping(mock_cluster))
    self.assertEqual(done, _is_cluster_done(mock_cluster))
    self.assertEqual(from_end_of_hour, _est_time_to_hour(mock_cluster, self.now))
    self.assertEqual(has_pending_steps, _cluster_has_pending_steps(mock_cluster._steps))
    self.assertEqual(idle_for, self.time_mock_cluster_idle(mock_cluster))
    self.assertEqual((pool_hash, pool_name), _pool_hash_and_name(pool_hash._bootstrapactions))
    self.assertEqual(running, _is_cluster_running(mock_cluster._steps))
    self.assertEqual(non_streaming, _is_cluster_non_streaming(mock_cluster._steps))

dataset/ETHPy150Open Yelp/mrjob/tests/tools/emr/test_terminate_idle_clusters.py ClusterTerminationTestCase.assert_mock_cluster_is/VarMisuse@152/245 `mock_cluster`->`pool_hash`