Workflow orchestration and management.
Project description
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
Built Distribution
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
Algorithm | Hash digest | |
---|---|---|
SHA256 | d1537c10f9affec0e782911218c55c541dadb5e1766ad9458c621e19090516b1 |
|
MD5 | 413b1483af58afdc1c21e258ff42bd1c |
|
BLAKE2b-256 | d4f8a084c257619905b0cdde43f3a4d4d6f645e7edf33aee3374bca51099817b |
File details
Details for the file prefect_client-2.20.11-py3-none-any.whl
.
File metadata
- Download URL: prefect_client-2.20.11-py3-none-any.whl
- Upload date:
- Size: 770.0 kB
- Tags: Python 3
- Uploaded using Trusted Publishing? No
- Uploaded via: twine/5.1.1 CPython/3.12.7
File hashes
Algorithm | Hash digest | |
---|---|---|
SHA256 | ef52f674619ed8274c6a10e76d8aa16010369c5d5994d88a8e606e2d619c19fc |
|
MD5 | e6e4439bddd6636d3ea8a29c13d2c3da |
|
BLAKE2b-256 | c6181ef3f4938cc73bf8a3f62c286ef624f0efad81092a8fd124fa37a5096173 |