Adam
07/08/2022, 2:47 PMJelle Vegter
07/08/2022, 2:59 PMJan Domanski
07/08/2022, 5:40 PMErick House
07/08/2022, 6:12 PMTim Helfensdörfer
07/08/2022, 6:30 PMFile "/Users/****/Library/Caches/pypoetry/virtualenvs/equation-kGZ4A1K9-py3.8/lib/python3.8/site-packages/prefect/cli/cloud.py", line 231, in login
exit_with_success(
File "/Users/****/Library/Caches/pypoetry/virtualenvs/equation-kGZ4A1K9-py3.8/lib/python3.8/site-packages/prefect/cli/_utilities.py", line 36, in exit_with_success
app.console.print(message, **kwargs)
AttributeError: 'PrefectTyper' object has no attribute 'console'
When trying to run (which worked in 2b7:
await login(
key=os.environ.get("PREFECT_API_KEY"),
workspace_handle=os.environ.get("PREFECT_WORKSPACE_HANDLE"),
)
Scott Henley
07/08/2022, 6:30 PMBinoy Shah
07/08/2022, 6:33 PMKevin Kho
Omar Sultan
07/08/2022, 9:10 PMWalter Cavinaw
07/08/2022, 9:37 PMApoorva Desai
07/08/2022, 11:13 PMJack Sundberg
07/09/2022, 7:09 PM# Minimal example of my current use, where I need to build filter objects
from prefect.client import get_client
from prefect.orion.schemas.filters import FlowFilter, FlowRunFilter
async with get_client() as client:
response = await client.read_flow_runs(
flow_filter=FlowFilter(
name={"any_": ["example-flow"]},
),
flow_run_filter=FlowRunFilter(
state={"name": {"any_": ["Completed", "Running"]}}
),
)
Is there a way to query with the client like this instead:
# Avoids the need to import and manually initialize FlowFilter+FlowRunFilter
from prefect.client import get_client
async with get_client() as client:
response = await client.read_flow_runs(
flow_filter={"name": {"any_": ["example-flow"]}},
flow_run_filter={"state": {"any_": ["Completed", "Running"]}},
)
Or even:
# Allows exact matching without use of {"any_": [...]}
from prefect.client import get_client
async with get_client() as client:
response = await client.read_flow_runs(
flow_filter={"name": "example-flow"},
flow_run_filter={"state": "Completed"},
)
Tom Klein
07/10/2022, 9:54 AMTom Klein
07/11/2022, 12:29 AMDaskExecutor
(that relies on a dask KubeCluster
) - are task Results handled in the flow, or is the Result handling delegated in the dask workers?
I'm asking because when we swap from a LocalExecutor
or a LocalDaskExecutor
to a DaskExecutor
- suddenly our S3Results (which all our tasks are configured with) seem to fail on AccessDenied
errors (for PutObject
attempts)
So logically it seems like they are being run from somewhere else that doesn't have the proper permissions (whereas the k8s job running the flow itself, does) --- am i missing something?Jack Sundberg
07/11/2022, 3:41 AMShivam Bhatia
07/11/2022, 6:20 AMdocker.errors.NotFound: 404 Client Error for <http+docker://localhost/v1.41/containers/ab511ceee07d320a6e458ba7a063b9cf92ba177e49bf84657e85b0f613ae6f4d/wait>: Not Found ("No such container: ab511ceee07d320a6e458ba7a063b9cf92ba177e49bf84657e85b0f613ae6f4d")
What am i missing?xyzz
07/11/2022, 7:51 AMAndreas
07/11/2022, 8:44 AMDeploymentSpec
are deprecated as of Prefect 2.0b8 release, does that mean that defining Deployments in YAML is going to also be depracated in the future? Can I still base my work on YAML?Slackbot
07/11/2022, 9:45 AMFlorian Guily
07/11/2022, 10:04 AMSuresh R
07/11/2022, 10:07 AMIevgenii Martynenko
07/11/2022, 10:14 AMIevgenii Martynenko
07/11/2022, 10:30 AMBogdan Serban
07/11/2022, 10:51 AMmap
function in an unmapped
call.
I am receiving an warning related to the size of the ml model that is being shared in the task graph (more details in the thread).
Is there an issue if I am receiving that error message? And is there a better way to share that ML model across the tasks?Mathieu Cayssol
07/11/2022, 11:20 AMJan
07/11/2022, 11:56 AMfrom prefect import task, flow
import time
@flow
def mijn_flow ():
return("just a string")
print(mijn_flow())
The output is:
135451.255 | INFO | prefect.engine - Created flow run 'brainy-parakeet' for flow 'mijn-flow'
135451.271 | INFO | Flow run 'brainy-parakeet' - Using task runner 'ConcurrentTaskRunner'
135451.302 | WARNING | Flow run 'brainy-parakeet' - No default storage is configured on the server. Results from this flow run will be stored in a temporary directory in its runtime environment.
135451.443 | INFO | Flow run 'brainy-parakeet' - Finished in state Completed()
Completed()
Can you point me into the correct direction?
I'm trying to access the return object of my flow (which is a string in this case).Alexandru Anghel
07/11/2022, 12:58 PMRuntimeError(f"Cluster failed to start: {e}") from e RuntimeError: Cluster failed to start: 503, message='Service Unavailable', url=URL('<http://proxy-ip-here>:proxy-port-here')
Any ideas on how to fix this? I've tried adding a NO_PROXY env variable alongside HTTPS_PROXY but it doesn't work.
I am using Prefect 1.2
Thanks!Black Spy
07/11/2022, 1:06 PMBinoy Shah
07/11/2022, 1:42 PM#dagster-*
channels compared to other communities and and it shows in the recommendations chart below under the light of our existing infra setup.
But I wanted to add more “fairness” to the evaluation ratings and I’d highly appreciate some constructive feedback from the community on where I can improve this rating.Florian Guily
07/11/2022, 1:55 PM