Wilson Bilkovich08/21/2021, 11:32 PM
Blake List08/22/2021, 3:26 AM
and t2 will be
. The next time schedule runs, t1 needs to be the previous value of t2, and t2 will once again be
. I can see that I may need to use a task to compute the parameters within the script of the parent flow (similar to here) and use the
task (as seen here), but I'm not quite sure how to put it together. Any help would be appreciated, thank you!!
Chintan Shah08/22/2021, 11:32 AM
. this is run time error while trying to execute flow . any pointers
An error occurred (ClientException) when calling the RegisterTaskDefinition operation: Container.image should not be null or empty
Ben Muller08/22/2021, 10:27 PM
Now after registering my flow I am getting an error after the flow is downloaded: in 🧵
S3( bucket="es-prefect-flows-staging", stored_as_script=True, )
Gaylord Cherencey08/23/2021, 3:51 AM
Eddie Atkinson08/23/2021, 5:06 AM
to process the data for each site individually, but does so for the entire range at once. The complication arises from the fact that the date range is specified as a parameter, and the site_ids are the result of a task that runs.
Chhaya Vankhede08/23/2021, 6:47 AM
Italo Barros08/23/2021, 11:48 AM
The error was solved after shutting down the agent and starting again at the same folder of his first execution. I think this is related to the agent metadata, is this behavior normal?
Failed to load and execute Flow's environment: FlowStorageError('An error occurred while unpickling the flow:\n ModuleNotFoundError("No module named \'Submodules\'",)\nThis may be due to a missing Python module in your current environment. Please ensure you have all required flow dependencies installed.',)
Wilson Bilkovich08/23/2021, 12:29 PM
object? Do I need one if I’m already specifying an Executor?
Jelle Vegter08/23/2021, 1:05 PM
Bastian Röhrig08/23/2021, 2:14 PM
I get my tenants, so if feel like I should be authenticated. I'm kind of stumped, maybe someone here has an idea?
prefect auth list-tenants
Traceback (most recent call last): File "/usr/local/lib/python3.7/site-packages/prefect/client/client.py", line 738, in _request json_resp = response.json() File "/usr/local/lib/python3.7/site-packages/requests/models.py", line 900, in json return complexjson.loads(self.text, **kwargs) File "/usr/local/lib/python3.7/json/__init__.py", line 348, in loads return _default_decoder.decode(s) File "/usr/local/lib/python3.7/json/decoder.py", line 337, in decode obj, end = self.raw_decode(s, idx=_w(s, 0).end()) File "/usr/local/lib/python3.7/json/decoder.py", line 355, in raw_decode raise JSONDecodeError("Expecting value", s, err.value) from None json.decoder.JSONDecodeError: Expecting value: line 1 column 1 (char 0) The above exception was the direct cause of the following exception: Traceback (most recent call last): File "/usr/local/bin/prefect", line 8, in <module> sys.exit(cli()) File "/usr/local/lib/python3.7/site-packages/click/core.py", line 829, in __call__ return self.main(*args, **kwargs) File "/usr/local/lib/python3.7/site-packages/click/core.py", line 782, in main rv = self.invoke(ctx) File "/usr/local/lib/python3.7/site-packages/click/core.py", line 1259, in invoke return _process_result(sub_ctx.command.invoke(sub_ctx)) File "/usr/local/lib/python3.7/site-packages/click/core.py", line 1259, in invoke return _process_result(sub_ctx.command.invoke(sub_ctx)) File "/usr/local/lib/python3.7/site-packages/click/core.py", line 1066, in invoke return ctx.invoke(self.callback, **ctx.params) File "/usr/local/lib/python3.7/site-packages/click/core.py", line 610, in invoke return callback(*args, **kwargs) File "/usr/local/lib/python3.7/site-packages/prefect/cli/execute.py", line 53, in flow_run result = client.graphql(query) File "/usr/local/lib/python3.7/site-packages/prefect/client/client.py", line 550, in graphql retry_on_api_error=retry_on_api_error, File "/usr/local/lib/python3.7/site-packages/prefect/client/client.py", line 454, in post retry_on_api_error=retry_on_api_error, File "/usr/local/lib/python3.7/site-packages/prefect/client/client.py", line 744, in _request ) from exc prefect.exceptions.AuthorizationError: Malformed response received from Cloud - please ensure that you are authenticated. See `prefect auth login --help`.
YD08/23/2021, 4:46 PM
. is it when you create the project in the cloud UI? what happens if one team create a project with the same name as a different team ?
Alex Furrier08/23/2021, 6:34 PM
from prefect import task from prefect.engine.result.local_result import LocalResult from my_prefect_tasks import imported_task @task(result=LocalResult()) def assigned_result_task(x): return x imported_task.result_handler = LocalResult()
Zach Schumacher08/23/2021, 9:07 PM
Vincent08/23/2021, 10:00 PM
Ours jobs are quite parallel, and wonder if there is anything that must be resolved, either user or server side that can enable this parallel execution.
requests.exceptions.RetryError: HTTPSConnectionPool(host='<http://api.prefect.io|api.prefect.io>', port=443): Max retries exceeded with url: /graphql (Caused by ResponseError('too many 429 error responses'))
Alex Furrier08/23/2021, 10:37 PM
that's returned by
Wilson Bilkovich08/23/2021, 10:46 PM
when I try to run a flow after making a small tweak to the pod spec. Anyone seen that before?
Unexpected error occured in FlowRunner: ModuleNotFoundError("No module named 'prefect'")
Maria08/24/2021, 1:14 AM
State message: An error occurred (ClientException) when calling the RegisterTaskDefinition operation: Too many concurrent attempts to create a new revision of the specified family.
Jacob Blanco08/24/2021, 6:40 AM
Robert Hales08/24/2021, 10:36 AM
Luiz Bezerra de Oliveira Lima Neto08/24/2021, 12:09 PM
Charles Leung08/24/2021, 3:11 PM
Wilson Bilkovich08/24/2021, 4:00 PM
Is this potentially because I’m running Python 3.9?
ERROR - prefect.FlowRunner | Unexpected error: TypeError('code() takes at most 15 arguments (16 given)')
Kyle Pierce08/24/2021, 5:03 PM
Error downloading Flow from S3: No module named 'boto3'
image. Is there something for extras or something we are missing?
Leon Kozlowski08/24/2021, 7:12 PM
wiretrack08/24/2021, 8:50 PM
field in the database, but could find a way to make the UI tenant specific, neither to register the flow for a specific tenant. Any ideas?
Tim Enders08/24/2021, 9:09 PM
Blake List08/24/2021, 11:33 PM
Running once then doing
import time import prefect from prefect import task, Flow from prefect.tasks.redis import RedisSet, RedisGet from prefect.tasks.control_flow import ifelse redis_get = RedisGet(...) redis_set = RedisSet(...) with Flow("flow_p") as flow: t1_get = redis_get(redis_key='t1_key') # true case t1_init = redis_set(redis_key='t1_key', redis_val="0000-00-00 00:00:00") # false case t1_set = redis_set(redis_key='t1_key', redis_val=time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())) ifelse(case(t1_get, None), t1_init, t1_set) flow.run()
but running again gives the same value. Any ideas why I am not getting the False case on the second run?
Jacob Blanco08/25/2021, 8:12 AM
st dabu08/25/2021, 8:55 AM