'Verify that when a source is deleted, the encrypted documents that
exist on disk is also deleted.'

def test_delete_source_deletes_docs_on_disk(self):

    self._delete_collection_setup()
    dir_source_docs = os.path.join(config.STORE_DIR, self.source.filesystem_id)
    self.assertTrue(os.path.exists(dir_source_docs))
    job = journalist.delete_collection(self.source.filesystem_id)
    utils.async.wait_for_redis_worker(job)
    self.assertFalse(os.path.exists(dir_source_docs))
