

def _lock_contents(self, mock_cluster, steps_ahead=0):
    conn = self.connect_s3()
    bucket = conn.get_bucket('my_bucket')
    lock_key_name = ('locks/%s/%d' % (bucket.id, (len(mock_cluster._steps) + steps_ahead)))
    key = bucket.get_key(lock_key_name)
    if (key is None):
        return None
    else:
        return key.get_contents_as_string()

dataset/ETHPy150Open Yelp/mrjob/tests/tools/emr/test_terminate_idle_clusters.py ClusterTerminationTestCase._lock_contents/VarMisuse@39/64 `mock_cluster`->`bucket`