Skip to main content

Workflow orchestration and management.

Project description

PyPI

prefect-client

The prefect-client package is a minimal-installation of prefect which is designed for interacting with Prefect Cloud or remote any prefect server. It sheds some functionality and dependencies in exchange for a smaller installation size, making it ideal for use in lightweight or ephemeral environments. These characteristics make it ideal for use in lambdas or other resource-constrained environments.

Getting started

prefect-client shares the same installation requirements as prefect. To install, make sure you are on Python 3.8 or later and run the following command:

pip install prefect-client

Next, ensure that your prefect-client has access to a remote prefect server by exporting the PREFECT_API_KEY (if using Prefect Cloud) and PREFECT_API_URL environment variables. Once those are set, use the package in your code as you would normally use prefect!

For example, to remotely trigger a run a deployment:

from prefect.deployments import run_deployment


def my_lambda(event):
    ...
    run_deployment(
        name="my-flow/my-deployment",
        parameters={"foo": "bar"},
        timeout=0,
    )

my_lambda({})

To emit events in an event driven system:

from prefect.events import emit_event


def something_happened():
    emit_event("my-event", resource={"prefect.resource.id": "foo.bar"})

something_happened()

Or just interact with a prefect API:

from prefect.client.orchestration import get_client


async def query_api():
    async with get_client() as client:
        limits = await client.read_concurrency_limits(limit=10, offset=0)
        print(limits)


query_api()

Known limitations

By design, prefect-client omits all CLI and server components. This means that the CLI is not available for use and attempts to access server objects will fail. Furthermore, some classes, methods, and objects may be available for import in prefect-client but may not be "runnable" if they tap into server-oriented functionality. If you encounter such a limitation, feel free to open an issue describing the functionality you are interested in using and we will do our best to make it available.

Next steps

There's lots more you can do to orchestrate and observe your workflows with Prefect! Start with our friendly tutorial or explore the core concepts of Prefect workflows.

Join the community

Prefect is made possible by the fastest growing community of thousands of friendly data engineers. Join us in building a new kind of workflow system. The Prefect Slack community is a fantastic place to learn more about Prefect, ask questions, or get help with workflow design. All community forums, including code contributions, issue discussions, and slack messages are subject to our Code of Conduct.

Contribute

See our documentation on contributing to Prefect.

Thanks for being part of the mission to build a new kind of workflow system and, of course, happy engineering!

Project details


Release history Release notifications | RSS feed

Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

prefect_client-2.20.13.tar.gz (777.2 kB view details)

Uploaded Source

Built Distribution

prefect_client-2.20.13-py3-none-any.whl (770.0 kB view details)

Uploaded Python 3

File details

Details for the file prefect_client-2.20.13.tar.gz.

File metadata

  • Download URL: prefect_client-2.20.13.tar.gz
  • Upload date:
  • Size: 777.2 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/5.1.1 CPython/3.12.7

File hashes

Hashes for prefect_client-2.20.13.tar.gz
Algorithm Hash digest
SHA256 96dbda9ce4ba039dd713dcae5b7f36334c217290a66061d7cdf6571bfc528c83
MD5 576682bfce3309fe309c5bfb97d49749
BLAKE2b-256 eae31a5971ee21298088dd165d01fe50fa5b524674b00fd465097ee73b18be13

See more details on using hashes here.

File details

Details for the file prefect_client-2.20.13-py3-none-any.whl.

File metadata

File hashes

Hashes for prefect_client-2.20.13-py3-none-any.whl
Algorithm Hash digest
SHA256 0ecae97366d8eaf21033434cc269b0229d40ddafbc34c4ad6e03015f3a4c7259
MD5 968ab2f42ec3d77e2d44818df476fc40
BLAKE2b-256 b55792a3a2e176a40d75d787725c841c4d82cbb18b35f3da4dbc01d751d4e06f

See more details on using hashes here.

Supported by

AWS AWS Cloud computing and Security Sponsor Datadog Datadog Monitoring Fastly Fastly CDN Google Google Download Analytics Microsoft Microsoft PSF Sponsor Pingdom Pingdom Monitoring Sentry Sentry Error logging StatusPage StatusPage Status page