Varuna Bamunusinghe
01/20/2022, 6:06 AMSuresh R
01/20/2022, 7:01 AMAnurag Bajpai
01/20/2022, 9:15 AMclient.get(f"repositories/{self.workspace}/{self.repo}/refs/branches")
call to get the list of branches actually returns a paginated list, and the method is not able to find the hash corresponding to the branch if the branch is not included in the first page. Additionally, the error raised in case the branch is not found is not formatted properly (it's a string instead of an f-string).Stefan Rasmussen
01/20/2022, 9:37 AMPhilipp Eisen
01/20/2022, 2:32 PMNo heartbeat detected from the remote task; marking the run as failed.
Is there some obvious things to look for?Thomas Opsomer
01/20/2022, 2:48 PMNo heartbeat detected...
. Usually It happens in 2 situations:
• the pod that run the tasks gets evicted / OOM killed
• the pod was running on a preemptible node that gets removed and replaced.
Is there something on the k8s agent, k8s job specification, or something else to configure to allow k8s to reschedule the job and let prefect know about it, so that the flow would continue ?!Florian Kühnlenz
01/20/2022, 4:40 PMPrasanth Kothuri
01/20/2022, 4:53 PMTomek Florek
01/20/2022, 5:13 PM@task
like _trigger=all_successful , log_stdout=True, max_retries_ etc. How can I set it up for these tasks? Would maybe using functions with decorators be advised as best practice here instead?Tim Enders
01/20/2022, 6:57 PMMatt Alhonte
01/20/2022, 8:40 PMMathijs Miermans
01/20/2022, 10:26 PMTom Shaffner
01/21/2022, 12:04 AMMathijs Miermans
01/21/2022, 12:26 AMSuresh R
01/21/2022, 8:03 AMKamil Gorszczyk
01/21/2022, 11:30 AMshijas km
01/21/2022, 11:59 AMGuilhelm PANAGET
01/21/2022, 1:23 PMKirk Quinbar
01/21/2022, 2:01 PMPhilipp Eisen
01/21/2022, 2:31 PMAlexander Kloumann
01/21/2022, 2:53 PMlogger = prefect.context.get("logger")
<http://logger.info|logger.info>("An info message.")
I tried running it from the interface on Prefect Cloud but that doesn't do anything either. What am I missing here?Stephen Herron
01/21/2022, 3:13 PMimport pandas
This doesn’t seem to work unless I specifically supply the custom image (and the task execution arn). I would have expected if run_config:image is null it would use the one from the task_definition? Does it default to something other than the container def?Luis Aguirre
01/21/2022, 5:02 PM*data*: {encoding: 'orion', blob: '{"encoding": "file", "blob": "file:///tmp/78442fec16214918a437e768fa384762"}'}
in the state
section. Is there something I should configure to get the whole response? ThanksPrateek Saigal
01/21/2022, 5:12 PMflow.schedule = CronSchedule("49 21 * * 1-5",start_date=pendulum.datetime(2022, 1, 1, tz="Asia/Kolkata"),)
flow.register(
project_name=project_name,
idempotency_key=flow.serialized_hash(),
labels=["test"],
)
What could be the reason for this?Leon Kozlowski
01/21/2022, 5:57 PMSuresh R
01/21/2022, 6:50 PMSeth Coussens
01/21/2022, 7:07 PMLeon Kozlowski
01/21/2022, 7:34 PMJason Motley
01/21/2022, 8:12 PMMatthew Millendorf
01/21/2022, 8:12 PMMatthew Millendorf
01/21/2022, 8:12 PMKevin Kho
01/21/2022, 8:29 PMquery{
task_run {
id
logs {
id
message
timestamp
}
}
}
and then specify your task_run id? or am i missing something?Matthew Millendorf
01/24/2022, 12:33 AM{
task_run(where: {flow_run_id: {_eq: '<flow_run_id>'}}) {
id
logs {
id
}
}
}
{
log(where :{task_run_id: {_eq:"<task_run_id>"}}) {
id
}
}
{
log(where :{flow_run_id: {_eq:"<flow_run_id>"}}) {
id
}
}
The query to populate a FlowRunView logs works, and am trying to modify it to work with the TaskRun IDKevin Kho
01/24/2022, 1:32 AMtask_run_by_pk
endpoint will be better. Try this
query{
task_run_by_pk(id: "5bcadf0c-e5c1-42c8-b468-48c7c927712e") {
id
flow_run_id
start_time
state
logs(
order_by: { timestamp: desc }
) {
id
level
message
name
timestamp
}
}
}