discdiver

import random
from prefect import flow, task


@task(name="Get data from API", retries=4, retry_delay_seconds=2)  # NEW ****
def call_unreliable_api():
    choices = [{"data": 42}, "failure"]
    res = random.choice(choices)
    if res == "failure":
        raise Exception("Our unreliable service failed")

discdiver

16:15:20.543 | INFO    | prefect.engine - Created flow run 'blue-flounder' for flow 'Previously unreliable pipeline'
16:15:20.612 | INFO    | Flow run 'blue-flounder' - Created task run 'Get data from API-466f2784-0' for task 'Get data from API'
16:15:20.613 | INFO    | Flow run 'blue-flounder' - Executing 'Get data from API-466f2784-0' immediately...
16:15:20.625 | ERROR   | Task run 'Get data from API-466f2784-0' - Encountered exception during execution:
Traceback (most recent call last):
  File "/Users/jeffhale/miniforge3/lib/python3.10/site-packages/prefect/engine.py", line 1048, in orchestrate_task_run
    result = await run_sync(task.fn, *args, **kwargs)
  File "/Users/jeffhale/miniforge3/lib/python3.10/site-packages/prefect/utilities/asyncutils.py", line 56, in run_sync_in_worker_thread
    return await anyio.to_thread.run_sync(call, cancellable=True)
  File "/Users/jeffhale/miniforge3/lib/python3.10/site-packages/anyio/to_thread.py", line 31, in run_sync

discdiver

import random
from prefect import flow, task

@task(name="Get data from API", retries=4, retry_delay_seconds=2)   # NEW ****
def call_unreliable_api():
    choices = [{"data": 42}, "failure"]
    res = random.choice(choices)
    if res == "failure":
        raise Exception("Our unreliable service failed")
    else:

discdiver

09:31:52.689 | INFO    | prefect.engine - Created flow run 'elite-hedgehog' for flow 'pipeline3'
09:31:52.748 | INFO    | Flow run 'elite-hedgehog' - Created task run 'call_unreliable_api-466f2784-0' for task 'call_unreliable_api'
09:31:52.749 | INFO    | Flow run 'elite-hedgehog' - Executing 'call_unreliable_api-466f2784-0' immediately...
09:31:52.771 | INFO    | Task run 'call_unreliable_api-466f2784-0' - Finished in state Completed()
09:31:52.782 | INFO    | Flow run 'elite-hedgehog' - Created task run 'augment_data-960bb844-0' for task 'augment_data'
09:31:52.782 | INFO    | Flow run 'elite-hedgehog' - Executing 'augment_data-960bb844-0' immediately...
09:31:52.801 | INFO    | Task run 'augment_data-960bb844-0' - Finished in state Completed()
09:31:52.810 | INFO    | Flow run 'elite-hedgehog' - Created task run 'write_results_to_database-fbbf5571-0' for task 'write_results_to_database'
09:31:52.811 | INFO    | Flow run 'elite-hedgehog' - Executing 'write_results_to_database-fbbf5571-0' immediately...
09:3

discdiver

import random
from prefect import flow, task    # NEW **** 

@task   # NEW ****
def call_unreliable_api():
    choices = [{"data": 42}, "failure"]
    res = random.choice(choices)
    if res == "failure":
        raise Exception("Our unreliable service failed")
    else:

discdiver

09:31:12.195 | INFO    | prefect.engine - Created flow run 'scarlet-avocet' for flow 'pipeline2'
09:31:12.256 | INFO    | Flow run 'scarlet-avocet' - Finished in state Completed()
Wrote {'data': 42, 'message': 'Trying a flow!'} to database successfully!

discdiver

import random
from prefect import flow    # NEW **** 

def call_unreliable_api():
    choices = [{"data": 42}, "failure"]
    res = random.choice(choices)
    if res == "failure":
        raise Exception("Our unreliable service failed")
    else:
        return res

discdiver

pipeline(msg="Super Special Message")

discdiver

import random 

def call_unreliable_api():
    choices = [{"data": 42}, "failure"]
    res = random.choice(choices)
    if res == "failure":
        raise Exception("Our unreliable service failed")
    else:
        return res

discdiver

1. See if you have Visual Studio Code installed by looking in your apps. If you don't, have it installed, install it from here
2. Configure Visual Studio Code to be your editor for git. From the command line run: git config --global core.editor "code -w"
3. Mac users: Set Visual Studio Code to open with code from the command line outside VS Code. Instructions here, press command + shift + p
4. Select Shell Command: Install 'code' command in PATH. Windows users should have the functionality automatically.
5. Install the Python extension for Visual Studio Code. Click on the Extensions icon in the left side bar and search for Python. Select and install it.
6. Make black your autoformatter. In the top menu bar go Code -> Preferences -> Settings and type black. Select Under Python > Formating: Provider select black. You may need to pip install black on the comma