import requests
from prefect import task, Flow
from prefect.engine.executors import DaskExecutor


@task(tags=["web"])
def retrieve_url():
    html = requests.get("http://www.insidethex.co.uk/")
    return "blah blah"


def run():
    with Flow("x-files") as flow:
        home_page = retrieve_url()

    executor = DaskExecutor(address="tcp://192.168.86.23:8786")
    state = flow.run(executor=executor)


if __name__ == "__main__":
    run()