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' % (
            mock_cluster.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/operator `+` -> `/`