Alex Furrier
02/10/2021, 5:19 PMMitchell Bregman
02/10/2021, 7:31 PMVerun Rahimtoola
02/10/2021, 7:40 PMwith Flow(...) as f:
param_1 = ...
param_2 = ...
...
param_n = ...
x = my_task([param_1, param_2, ..., param_n])
Verun Rahimtoola
02/10/2021, 7:42 PMVincent
02/10/2021, 7:51 PMJonathan Lowery
02/10/2021, 8:16 PMJames Phoenix
02/10/2021, 9:33 PMJames Phoenix
02/10/2021, 9:33 PMJames Phoenix
02/10/2021, 9:34 PMfrom clean_energy.client_wrappers.prefect_flows.flows import test #THIS IS A FLOW
from flask import (Blueprint)
prefect_client_routes = Blueprint('prefect_client_routes', __name__, url_prefix="/api/prefect")
import prefect
from config.settings import Config
client = prefect.Client(api_token=Config.PREFECT_USER_TOKEN)
@prefect_client_routes.route('/')
def testing():
return test.register(project_name='clean_energy')
James Phoenix
02/10/2021, 9:34 PMJames Phoenix
02/10/2021, 9:34 PMprefect.utilities.exceptions.ClientError: [{'path': ['project'], 'message': 'field "project" not found in type: \'query_root\'', 'extensions': {'path': '$.selectionSet.project', 'code': 'validation-failed', 'exception': {'message': 'field "project" not found in type: \'query_root\''
James Phoenix
02/10/2021, 9:34 PMJames Phoenix
02/10/2021, 9:34 PMJames Phoenix
02/10/2021, 9:35 PMJames Phoenix
02/10/2021, 9:35 PMShawn Marhanka
02/10/2021, 10:18 PMDanny Vilela
02/11/2021, 3:27 AMflow.parameters() -> Set[Parameter]
. But it seems like the implementation is “shallow,” in that it just checks for top-level tasks that are parameters (as opposed to recursively pulling parameters from tasks):
def parameters(self) -> Set[Parameter]:
"""
Returns any parameters of the flow.
Returns:
- set: a set of any Parameters in this flow
"""
return {p for p in self.tasks if isinstance(p, Parameter)}
Is there a reasonable way to extend the Flow class to search for all parameters declared within the Flow(..) as flow
context manager?sark
02/11/2021, 7:02 AMKarolĂna Bzdušek
02/11/2021, 8:44 AMLaura Vaida
02/11/2021, 9:39 AMJan Marais
02/11/2021, 9:48 AMEmailTask
is text/html but it seems that this is hard coded. Would it make sense to have it as a parameter to the task in the future? I just have some plain text to be sent and gmail is not parsing my newlines properly.Ruben
02/11/2021, 11:22 AMGareth Dwyer
02/11/2021, 11:56 AM404 Client Error for <http+docker://localhost/v1.40/containers/create>: Not Found ("No such image: prefecthq/prefect:0.14.7")
Did I do something wrong or is this related to the new 14.7 release that I see on GitHub?Adam
02/11/2021, 12:42 PMNikul
02/11/2021, 2:16 PMMichael Hadorn
02/11/2021, 4:26 PMprefect.utilities.exceptions.ClientError: 400 Client Error: Bad Request for url: <http://host.docker.internal:4200/graphql>
The following error messages were provided by the GraphQL server:
INTERNAL_SERVER_ERROR: Variable "$input" got invalid value null at
"input.states[0].task_run_id"; Expected non-nullable type UUID! not to be null.
The GraphQL query was:
mutation($input: set_task_run_states_input!) {
set_task_run_states(input: $input) {
states {
status
message
id
}
}
}
The passed variables were:
{"input": {"states": [{"state": {"message": "Starting task run.", "cached_inputs": {}, "context": {"tags": []}, "_result": {"__version__": "0.14.6", "type": "NoResultType"}, "__version__": "0.14.6", "type": "Running"}, "task_run_id":
null, "version": null}]}}
locally and also with the local agent on the ui server it's working.Asif Imran
02/11/2021, 5:27 PM<http://cloud.prefect.io|cloud.prefect.io>
offer two-factor authentication?Luis Gallegos
02/11/2021, 5:34 PMMilly gupta
02/11/2021, 10:27 PMMarwan Sarieddine
02/11/2021, 11:58 PM