Ken Nguyen
05/18/2022, 10:31 PMTypeError: Task is not iterable. If your task returns multiple results, pass `nout` to the task decorator/constructor, or provide a `Tuple` return-type annotation to your task.
Pasha Kravtsov
05/18/2022, 10:43 PMpaimoe
05/19/2022, 1:24 AMprefect backend server
in ENV variables? since it's complaining about no API keyEddie Atkinson
05/19/2022, 3:43 AMcluster
which determines whether a cluster is used which is accessed from a callback to DaskCluster
. However, it’s not actually used in the flow which is causing flow run failures locally because it’s an ‘unexpected parameter’. I am 90% sure I’ve seen a way before where I can say to Prefect to relax and that it’s fine (technical terminology), but can’t remember exactly howRaviraja Ganta
05/19/2022, 5:45 AMTypeError: cannot pickle 'google.protobuf.pyext._message.MessageDescriptor' object
Guillaume Latour
05/19/2022, 8:20 AMdistributed.protocol.pickle - INFO - Failed to serialize <Success: "Task run succeeded.">. Exception: cannot pickle 'lxml.etree.XMLSchema' object
which leads to
distributed.worker - ERROR - failed during get data with <ip> -> <ip>
which at some point close the connexion
distributed.comm.core.CommClosedError: in <TCP (closed) local=tcp://<ip> remote=tcp://<ip>>: Stream is closed
this is managed by prefect by some retries (depending on configuration) and finally the agent raises an error and the flow is marked as failling
distributed.scheduler.KilledWorker: ('concatenate_df_based_on_time-b91c06dc30f54c5084e9f5fe8b6b32a5', <WorkerState 'tcp://<ip>', status: closed, memory: 0, processing: 1>)
Do you have an idea on how to prevent this kind of error?Jan Domanski
05/19/2022, 9:11 AMTom Manterfield
05/19/2022, 10:50 AMSander
05/19/2022, 2:15 PMfrom logging import getLogger
logger = getLogger(__name__)
Class MyClass:
def __init__(self):
pass
def my_method(self):
<http://logger.info|logger.info>(‘hi’)
Does that make sense?Vadym Dytyniak
05/19/2022, 3:18 PMKyle Austin
05/19/2022, 3:34 PMJohn Muddle
05/19/2022, 3:47 PMDylan
05/19/2022, 5:51 PMjob_template_path
now. Same template loaded via S3 during flow init didn’t throw this error, but registration blows up with this error now.Jacqueline Riley Garrahan
05/19/2022, 7:07 PMprefect_test_harness
in 2.0 and am wondering if any such fixtures exist for 1.2? Are there any general guides for setting up tests for projects using prefect?Florian Guily
05/19/2022, 7:50 PMprefect auth list-keys
command but not in prefect cloud. Is it normal ?Madison Schott
05/19/2022, 8:02 PMNikhil Jain
05/19/2022, 9:19 PMstorage.add_flow()
method. Is there a way around it?Nikhil Jain
05/19/2022, 9:34 PMDylan
05/19/2022, 10:22 PMLuke Segars
05/20/2022, 12:38 AMNash Taylor
05/20/2022, 1:15 AMpip install prefect>=2.0b
) into an environment with mypy, and since there doesn’t appear to be a py.typed
file in prefect
, mypy is skipping it:
Skipping analyzing "prefect": module is installed, but missing library stubs or py.typed marker
I threw a py.typed in there (touch py.typed
), but obviously this is less than ideal. Am I missing something obvious?Luke Segars
05/20/2022, 2:30 AMDaniel Sääf
05/20/2022, 5:48 AMSylvain Hazard
05/20/2022, 8:57 AMloguru
logger in Prefect tasks as described here.
At first glance it works pretty well but it looks like DEBUG
logs aren't sinked into Prefect. Any idea what I could do ?Sander
05/20/2022, 9:29 AMMarwan Sarieddine
05/20/2022, 11:57 AMValentin Baert
05/20/2022, 11:59 AMflow
decorated function "MissingContextError: No settings context found"
What am I missing ?Florian Guily
05/20/2022, 1:28 PM--param bool_param=True
but True
is treated as a String during flow execution. How can i pass a boolean param in cli for flow run ?Suresh R
05/20/2022, 1:48 PMAndrew Lawlor
05/20/2022, 2:32 PMKubernetes Error: pods failed
and no container statuses found for pod
and in GKE i see SyncLoop DELETE
and audit_log, method: "io.k8s.core.v1.pods.delete", principal_email: "system:serviceaccount:kube-system:generic-garbage-collector"
and SyncLoop REMOVE
Andrew Lawlor
05/20/2022, 2:32 PMKubernetes Error: pods failed
and no container statuses found for pod
and in GKE i see SyncLoop DELETE
and audit_log, method: "io.k8s.core.v1.pods.delete", principal_email: "system:serviceaccount:kube-system:generic-garbage-collector"
and SyncLoop REMOVE
Kevin Kho
05/20/2022, 2:39 PM