DK
03/08/2022, 7:26 PMDavid Beck
03/08/2022, 10:22 PMPREFECT__CLOUD__SEND_FLOW_RUN_LOGS=False
in our global container config which I see being recognized by Prefect Cloud, however there are logs still populating for the run (see attached). Do I perhaps have the wrong value defined or could I be missing something?Daniel Nilsen
03/11/2022, 12:16 PMTypeError: Cannot set properties of undefined (setting 'role')
Anyone know what this means?Amogh Kulkarni
03/14/2022, 8:16 PMRussell Brooks
03/16/2022, 10:53 PMRussell Brooks
03/16/2022, 10:56 PMRuslan
03/19/2022, 2:14 PMYury Cheremushkin
03/21/2022, 4:02 PMimport pendulum
from datetime import timedelta
from prefect import Parameter, task, Flow
from prefect.schedules import Schedule
from prefect.schedules.clocks import IntervalClock
schedule = Schedule(clocks=[IntervalClock(start_date=pendulum.datetime(2021, 9, 28, 8, 0, 0, tz="UTC"), interval=timedelta(minutes=10))])
params = {
"message": "message version 1"
}
with Flow("test_changing_parameters_from_ui", schedule=schedule) as flow:
p = Parameter("params", default=params)
task(lambda x: print(x))(p["message"])
I register it in Prefect Cloud. And right after registration Prefect Cloud schedules 10 runs of my Flow.
After that i change message
in this Flow via Cloud UI. For example, set "message": "message version 2"
.
I expect that in the next run updated message will be printed for me. But in fact I need to wait for 10 more runs before i'll be able to see my "message version 2".Architha Rao
03/23/2022, 6:41 AMAdam Knust
03/31/2022, 6:02 PMLeonardo Rocha
04/04/2022, 8:49 PM@task
def file_write(x):
print(x)
with open('test_result.txt', 'a') as f:
f.write(str(x))
return x
with Flow("priority_test", executor=LocalDaskExecutor()) as flow:
with dask.annotate(priority=-10):
written1 = file_write(2)
with dask.annotate(priority=0):
written2 = file_write(1)
with dask.annotate(priority=10):
written3 = file_write(0)
I expected it to write "012", but am consistently getting "201"Dev Dua
04/05/2022, 4:55 AMPREFECT_API_URL
) to 0.0.0.0:4200/api
Is there another way to accomplish this?Russell Brooks
04/06/2022, 7:37 AMMeng Si
04/06/2022, 4:52 PMSam Garvis
04/06/2022, 6:30 PMVadym Dytyniak
04/07/2022, 12:41 PMRAISS Zineb
04/07/2022, 2:05 PMAtsushi Saito
04/07/2022, 5:50 PMKonstantin
04/12/2022, 2:29 PMRAISS Zineb
04/15/2022, 2:35 PMTim Helfensdörfer
04/19/2022, 7:49 AMArkady K.
04/19/2022, 1:17 PMArkady K.
04/19/2022, 1:18 PMDomenico Di Gangi
04/19/2022, 1:37 PMBenoit Chabord
04/19/2022, 8:43 PMJoseph Mathes
04/22/2022, 4:57 PMSander
04/23/2022, 6:18 PMSander
04/23/2022, 6:36 PMSander
04/23/2022, 7:49 PMBlake Enyart
04/25/2022, 3:40 PM