# Here's an example of what I'm thinking
corpus_file = 'corpus.txt'
@task(target=corpus_file, result=LocalResult())
def write_sentence_corpus(sentences):
    with open(corpus_file, 'w') as fp:
        for sent in sentences:
            fp.write(sent + '\n')

with Flow("text_model") as f:
    sentences = extract_sentences()
    corpus = write_sentence_corpus(sentences)
    ...
    # Do more modelling