def METHOD_NAME(self, celery, session):
    session.add_all(
        [
            self._one(37.0, 6.0, self.today),
            self._one(37.0, 6.1, self.today - timedelta(days=366)),
            self._one(37.0, 4.0, self.today),
            self._one(37.0, 4.1, self.today - timedelta(days=366)),
            self._one(10.0, 6.0, self.today),
            self._one(10.0, 6.1, self.today - timedelta(days=366)),
            self._one(10.0, 4.0, self.today),
            self._one(10.0, 4.1, self.today - timedelta(days=366)),
        ]
    )
    session.flush()
    for shard_id, shard in DataMap.shards().items():
        cleanup_datamap.delay(shard_id=shard_id).get()
        assert session.query(shard).count() == 1