Ross Teach
09/15/2022, 1:44 PMprefect.exceptions.PrefectHTTPStatusError: Server error '500 Internal Server Error' for url '<https://api.prefect.cloud/api/accounts/043b2649-9d07-4c5e-8225-521ba2275e68/workspaces/689b139b-a725-4c2b-b167-86a705b8789d/task_runs/7d0c4bc0-a212-49b3-94e2-f1b9bdee765f/set_state>'
Response: {'exception_message': 'Internal Server Error'}
For more information check: <https://httpstatuses.com/500>
Mark Li
09/15/2022, 3:03 PMError: failed to fetch <https://prefecthq.github.io/prefect-helm/charts/orion/prefect-orion-0.5.1.tgz> : 404 Not Found
The target version is: 2.3-python3.9.
Has something changed to where this file no longer exists? That assumption doesn’t seem quite right.Sharvil Popli
09/15/2022, 3:04 PMstart_date = Parameter("start_date", default="2022-09-11")
What I see on the UI after registering the flow is in the first attached image. start_date shows up as string. What I’d like to see by default is in the second image, I’d like start_date to show up as date type instead of as string with the date time picker functionality. How can I achieve this?José Duarte
09/15/2022, 4:36 PMSeth Coussens
09/15/2022, 4:51 PMChris Gunderson
09/15/2022, 5:15 PMNick Coy
09/15/2022, 5:34 PMTony Piazza
09/15/2022, 5:51 PMSlackbot
09/15/2022, 6:27 PMKrishnan Chandra
09/15/2022, 6:33 PMAnyUrl
or subclasses within the code, do you have any idea what might be causing the pickle error?Ching
09/15/2022, 7:10 PMfrom prefect import flow
import pandas as pd
import numpy as np
@flow
def do_nothing(df):
return None
if __name__ == "__main__":
df = pd.DataFrame(np.random.random((10_000, 20)))
do_nothing(df)
Traceback in threadHarrison Kim
09/15/2022, 7:35 PMHallen Maia
09/15/2022, 8:35 PMkiran
09/15/2022, 9:34 PMPranit
09/16/2022, 6:02 AMJosé Duarte
09/16/2022, 10:37 AMeddy davies
09/16/2022, 12:06 PMChris Gunderson
09/16/2022, 1:39 PMStéphan Taljaard
09/16/2022, 1:44 PMModuleNotFoundError: No module named 'gcsfs'
It's strange because the environment that my agent is running in has gsfs
installed and I have "EXTRA_PIP_PACKAGES": "gcsfs"
in my Docker Block...
Any tips?Mark Li
09/16/2022, 4:25 PMRay Bell
09/16/2022, 4:41 PMXavier Babu
09/16/2022, 5:01 PMStephen Herron
09/16/2022, 5:06 PMJosh Paulin
09/16/2022, 6:00 PMNikhil Jain
09/16/2022, 6:47 PMSubmitted for execution: Task arn:aws:ecs:us-west-2:<>:task/prod-prefect-cluster/c01a3ca13b3741a89e58b6c33dda0671
INFO prefect-server.Lazarus.FlowRun Rescheduled by a Lazarus process. This is attempt 1.
Any tips on how to debug this? I can’t find the logs for these tasks in cloudwatch.Philip MacMenamin
09/16/2022, 7:21 PMChris Gunderson
09/16/2022, 7:52 PMLeon Kozlowski
09/16/2022, 8:57 PMclient.create_flow_run
work off of flow group ids?
{
flow(
where: {name: {_eq: "FLOW_NAME"}, archived: {_eq:false}},
order_by: {created: desc}
) {
id
name
project {
name
}
}
}
Sergiy Popovych
09/16/2022, 9:27 PMasaf alina
09/17/2022, 1:21 PMmain
flow, which calls to a subflow go_eat
, each time with different parameters.
something of the sort:
@flow
def go_eat():
...
@flow
def main():
animals = ['dog', 'cat', 'monkey']
for animal in animals:
go_eat(animal)
I want to make those go_eat
flows to run in parallel, and I wonder how to implement this.
it would be best if I could make up to 2 animals to go_eat
in parallel, but no more than that.
I'm not sure if I somehow better use the prefect queue concurrency mechanism, or if I better implement this in pure python.
any suggestions?