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

Adds PlanetaryComputerTaskRunner #12

Merged
merged 3 commits into from
Aug 5, 2023
Merged

Adds PlanetaryComputerTaskRunner #12

merged 3 commits into from
Aug 5, 2023

Conversation

giorgiobasile
Copy link
Owner

Provides a PlanetaryComputerTaskRunner based on dask_gateway.DaskTaskRunner.

Closes #11

Example

from prefect import flow
from prefect_planetary_computer.task_runners import PlanetaryComputerTaskRunner

pc_credentials = PlanetaryComputerCredentials.load("BLOCK_NAME")

pc_runner = PlanetaryComputerTaskRunner(
    credentials=pc_credentials
)

@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 5, 2023
@giorgiobasile giorgiobasile self-assigned this Aug 5, 2023
@giorgiobasile giorgiobasile marked this pull request as draft August 5, 2023 11:58
@giorgiobasile giorgiobasile force-pushed the pc-task-runner branch 3 times, most recently from df81739 to eab05ca Compare August 5, 2023 12:07
@giorgiobasile giorgiobasile marked this pull request as ready for review August 5, 2023 12:10
@giorgiobasile giorgiobasile merged commit 6f50aba into main Aug 5, 2023
5 checks passed
@giorgiobasile giorgiobasile deleted the pc-task-runner branch August 5, 2023 12:15
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.

Add specialised TaskRunner for PC Dask Gateway
1 participant