Lucien Fregosi
07/26/2022, 1:46 PMgcsfs
dependency (using GCS as a RemoteFileSystem
)
I guess this dependency should be added to the docker image or maybe it’s possible to specify additional libs ?haris khan
07/26/2022, 1:54 PMJyothi
07/26/2022, 2:19 PMJyothi
07/26/2022, 2:21 PMdef escalate(obj, old_state, new_state):
if new_state.is_failed() and new_state.message not in IGNORE_MESSAGES:
msg = f"{obj} {new_state.message}"
slack_post(msg, channel="#errors", username="Prefect")
return new_state
and i would like to
def escalate(obj, old_state, new_state, error_channel="#errors"):
because i need have different channel for some flowsiñigo
07/26/2022, 2:27 PMAndreas Nigg
07/26/2022, 2:43 PMMichael Reynolds
07/26/2022, 3:11 PMorion
for non-terminating long running workflows?Slackbot
07/26/2022, 3:15 PMChris Reuter
07/26/2022, 4:49 PMChu
07/26/2022, 5:16 PMcreate_flow_run(trigger = all_successful)
Mike Grabbe
07/26/2022, 5:39 PMSebastián Montoya Tapia
07/26/2022, 8:14 PMGeert-Jan Van den Bogaerde
07/26/2022, 9:51 PMCharles Phares
07/27/2022, 12:43 AMflow.run()
"
Yeah. Exactly.
...and where would I find these logs???Viet Nguyen
07/27/2022, 1:13 AMChris Hansen
07/27/2022, 2:25 AMFaheem Khan
07/27/2022, 3:11 AMPedro Machado
07/27/2022, 5:46 AMfiles
argument in 1.0 Docker storage). ThanksEd Burroughes
07/27/2022, 7:51 AMRiccardo Tesselli
07/27/2022, 8:59 AMResponse: {'detail': 'The request specified API version 0.7.0 but this serverrequires version 0.8.0 or higher.'}
btw I’m using default image for KubernetesJob and my code is up to date with version 2.0b15
Viet Nguyen
07/27/2022, 11:40 AMImportError: cannot import name 'DaskTaskRunner' from partially initialized module 'prefect_dask' (most likely due to a circular import)
I used 2.0b15
latest prefect-dask
on Python 3.8.13
3.9
3.8.4
3.7.13
(freshly installed Conda envs), I'm wondering if you have come across this issue before? Many thanksSana Shaikh
07/27/2022, 11:41 AMBenjamin.bgx
07/27/2022, 1:10 PMFileNotFoundError: [Errno 2] No such file or directory: 'python'
when running a flow on an agent from prefect cloud 2 ?Josh Paulin
07/27/2022, 1:27 PMThis flow is archived and cannot be run
, when I flip back to an old version. Wanted to make sure that’s always expected and I’m not just doing something wrong when registering new versions of the flow.Stephen Herron
07/27/2022, 1:46 PMprefect register flows
workflow does not appear to return an error code when the there’s a issue with deploying a flow..
Only thing I can see I’m doing differently is that i’m using a matrix to
• for each prefect project
• deploy changed flows in each project
has anyone had this problem before?Adam
07/27/2022, 3:13 PMJack Sundberg
07/27/2022, 3:52 PMJohn
07/27/2022, 4:04 PM@task
def update_task(file_type: str):
update_files(file_type=file_type)
@flow
def update_flow(file_type: str):
update_task(file_type=file_type)
if __name__ == '__main__':
update_flow(file_type="incremental")
I am running it as python -m tasks.prefect_flows.update_flow
. This takes 10+ minutes to run. By comparison, just running the same code with a click CLI takes 10s. Any idea what's going on?Chris Hansen
07/27/2022, 4:21 PMJehan Abduljabbar
07/27/2022, 5:02 PMJehan Abduljabbar
07/27/2022, 5:02 PMKhuyen Tran
07/27/2022, 5:12 PMJehan Abduljabbar
07/27/2022, 5:17 PMAndrew Huang
07/27/2022, 6:31 PMwhich dbt
Anna Geller
07/27/2022, 7:00 PMJehan Abduljabbar
07/27/2022, 8:54 PMAnna Geller
07/28/2022, 12:32 AMJehan Abduljabbar
07/28/2022, 12:12 PM