Skip to content
This repository has been archived by the owner on Jul 15, 2024. It is now read-only.

Credentials task runner getter #17

Merged
merged 3 commits into from
Aug 11, 2023
Merged

Conversation

giorgiobasile
Copy link
Owner

Closes #16

Example

from prefect import flow

pc_credentials = PlanetaryComputerCredentials.load("BLOCK_NAME")
pc_runner = pc_credentials.get_dask_task_runner()

@flow(task_runner=pc_runner)
def my_flow():
    ...

Screenshots

Checklist

  • References any related issue by including "Closes #" or "Closes ".
    • If no issue exists and your change is not a small fix, please create an issue first.
  • Includes tests or only affects documentation.
  • Passes pre-commit checks.
    • Run pre-commit install && pre-commit run --all locally for formatting and linting.
  • Includes screenshots of documentation updates.
    • Run mkdocs serve view documentation locally.
  • Summarizes PR's changes in CHANGELOG.md

@giorgiobasile giorgiobasile added the enhancement New feature or request label Aug 11, 2023
@giorgiobasile giorgiobasile self-assigned this Aug 11, 2023
@giorgiobasile giorgiobasile merged commit 0624ac4 into main Aug 11, 2023
@giorgiobasile giorgiobasile deleted the credentials-task-runner-getter branch August 11, 2023 10:57
Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Labels
enhancement New feature or request
Projects
None yet
Development

Successfully merging this pull request may close these issues.

Provide configured DaskTaskRunner instead of subclassed task runner
1 participant