How to use requests session in Flow

[tonal]

How to best rewrite code:

from prefect import task, Flow
from prefect.tasks.secrets import PrefectSecret
import requests

@task
def create_session(auth):
  session = requests.session(auth=auth)
  # + other config session.
  return session

@task
def get_items():
  return [1, 2, 3]

@task
def load_item(session, item):
  res = session.get(url, json=item)

with Flow('get some datas') as flow:
  auth = PrefectSecret('auth')
  session = create_session(auth)
  items = get_items()
  load_item.map(session=unmapped(session), item=items)

[joshmeek]

Hi @tonal could you clarify what you are asking here? If you're referencing passing around a requests session that other tasks could use I would take a look at the ResourceManager tasks: https://docs.prefect.io/api/latest/tasks/resources.html#resourcemanager. This is commonly used for safely passion around client instances and such.