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.11.tar.gz (777.0 kB view details)

Uploaded Source

Built Distribution

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

Uploaded Python 3

File details

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

File metadata

  • Download URL: prefect_client-2.20.11.tar.gz
  • Upload date:
  • Size: 777.0 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.11.tar.gz
Algorithm Hash digest
SHA256 d1537c10f9affec0e782911218c55c541dadb5e1766ad9458c621e19090516b1
MD5 413b1483af58afdc1c21e258ff42bd1c
BLAKE2b-256 d4f8a084c257619905b0cdde43f3a4d4d6f645e7edf33aee3374bca51099817b

See more details on using hashes here.

File details

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

File metadata

File hashes

Hashes for prefect_client-2.20.11-py3-none-any.whl
Algorithm Hash digest
SHA256 ef52f674619ed8274c6a10e76d8aa16010369c5d5994d88a8e606e2d619c19fc
MD5 e6e4439bddd6636d3ea8a29c13d2c3da
BLAKE2b-256 c6181ef3f4938cc73bf8a3f62c286ef624f0efad81092a8fd124fa37a5096173

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