Daniil Ponizov
12/10/2021, 2:49 PMline 831, in _verify_token
raise AuthorizationError("No agent API token provided.")
prefect.exceptions.AuthorizationError: No agent API token provided.
Stephen Herron
12/10/2021, 3:49 PMalex
12/10/2021, 4:55 PMimport app.logic
@task
def do_something():
app.logic.dosomething()
If I am using a Local Agent and modify
app.logic.dosomething()
without modifying the task or the general flow structure, would I still need to redeploy my flow?Scott Hood
12/10/2021, 5:21 PMKevin Kho
Shaoyi Zhang
12/10/2021, 5:33 PMMartim Lobao
12/10/2021, 5:37 PMdammy arinde
12/10/2021, 5:43 PMjustabill
Executor
more explicit, we have renamed Executor
to TaskRunner
🏃.
Check out the release notes to learn more about the other enhancements and fixes.Leon Kozlowski
12/10/2021, 7:47 PMTilak Maddy
12/11/2021, 11:34 AMadd_flow_group_schedule
instead of just
set_flow_group_schedule
(Just like we have in the UI ~ The New Schedule button) -> How does it manage to do it ?Alvaro Durán Tovar
12/11/2021, 6:42 PMLuke Segars
12/12/2021, 4:17 AMadd(1, 10, 100)
, add(1, 10, 200)
, add(1, 10, 300)
, add(1, 20, 100)
, etc, with combinations similar to the results of itertools.product
in standard python
@task
def add(x, y, z):
return x + y + z
@task
def print_all(results):
print(results)
with Flow('Run combinations') as flow:
a = [1, 2, 3]
b = [10, 20, 30]
c = [100, 200, 300]
results = add.map(a, b, c)
print_all(results)
flow.run()
An Hoang
12/12/2021, 4:48 PMtarget
keyword argument for all tasks at flow level? I have some tasks with target
caching and for testing I would like all the result files to be created again without caching. If we can selectively decide which one to override for a particular run that would be even betterRoyzac
12/12/2021, 10:19 PMRoyzac
12/12/2021, 10:30 PMNoam polak
12/13/2021, 7:31 AMIdo Slonimsky
12/13/2021, 10:04 AMAn Hoang
12/13/2021, 1:55 PMflow_result = flow.run(...)
? I'm missing a couple of output files and I have no idea where they are saved so trying to hunt them down to prevent memory leak (not in my expected folder and also not in ~/.prefect/results
)Alvaro Durán Tovar
12/13/2021, 2:04 PMWieger Opmeer
12/13/2021, 2:10 PMIdo Slonimsky
12/13/2021, 2:51 PMflow.register(project_name="test-project")
What is the best practice to importing common .py files? Since at the moment the simple
from utils import util
fails with an error:
Failed to load and execute Flow's environment: ModuleNotFoundError("No module named 'utils'")
Thomas Hoeck
12/13/2021, 3:24 PMTraceback (most recent call last):
File "register_flows.py", line 20, in <module>
register_flows(all_flows)
File "register_flows.py", line 14, in register_flows
prefect_client.register(
File "/root/miniconda3/lib/python3.8/site-packages/prefect/client/client.py", line 1242, in register
self.graphql(
File "/root/miniconda3/lib/python3.8/site-packages/prefect/client/client.py", line 569, in graphql
raise ClientError(result["errors"])
prefect.exceptions.ClientError: [{'path': ['set_schedule_active'], 'message': "Required parameters were not supplied: {'version1', 'version2'}", 'extensions': {'code': 'INTERNAL_SERVER_ERROR'}}]
An Hoang
12/13/2021, 5:04 PMprefect run --execute
. I was going to do ShellTask("prefect run --execute").run()
but thought there might be another way. Maybe create_flow_run
?John
12/13/2021, 5:21 PM{{ prev_execution_date_success }}
in airflow).
i’ve had some success querying the prefect API, although one issue i’ve run into is that task ids change with each version of the task. perhaps that’s fine, but i’m curious if anyone has approached the problem in a different way.Sean Leakehe
12/13/2021, 10:33 PMfunc4
to have an upstream dependency on func1
, it executes at the same time as func2
, as expected. However, if we make func4
a mapped task with the same upstream dependency on func1
, it doesn’t actually execute until after func3
has finished. Is there a way to get mapped tasks to run in parallel?Sean Leakehe
12/13/2021, 10:33 PMJohn Muehlhausen
12/14/2021, 12:54 AMprefect agent local start {...}
Tilak Maddy
12/14/2021, 10:30 AMJeremiah Lethoba
12/14/2021, 12:23 PM