Rezwan Abir
02/13/2023, 10:02 PM"failed to validate that project [studio] and domain [development] are registered, err: [project [studio] not found]\"}\"\n>>"}
David Espejo (he/him)
02/13/2023, 10:03 PMRezwan Abir
02/13/2023, 10:04 PMDavid Espejo (he/him)
02/13/2023, 10:04 PMflytesnacks
Rezwan Abir
02/13/2023, 10:06 PM<_InactiveRpcError of RPC that terminated with:
status = StatusCode.INTERNAL
details = "failed to compile workflow for [resource_type:WORKFLOW project:"flytesnacks" domain:"development" name:"app.flyte.client.process_data_wf" version:"1.0" ] with err failed to compile workflow with err Collected Errors: 1
@workflow
def process_data_wf(kickoff_time: datetime):
print("SOME WORKFLOW...........")
return "done"
def execute_custom_dashboard_workflow(
self, jwt: str, account_id: UUID, user_id: UUID, report_id: UUID
) -> str:
launch_plan = LaunchPlan.get_or_create(
self.process_data_wf,
name="wf_launchplan",
schedule=FixedRate(duration=timedelta(minutes=1))
)
try:
self.remote.register_workflow(self.process_data_wf, version='1.0')
execution = self.remote.execute(launch_plan, inputs={}, version='1.0', project='flytesnacks', domain=self.settings.flyte_domain)
except Exception as e:
print("Error.....", e)
return execution
Error 0: Code: NoNodesFound, Node Id: resource_type:WORKFLOW project:"flytesnacks" domain:"development" name:"app.flyte.client.process_data_wf" version:"1.0" , Description: Can't find any nodes in workflow [resource_type:WORKFLOW project:"flytesnacks" domain:"development" name:"app.flyte.client.process_data_wf" version:"1.0" ].
David Espejo (he/him)
02/13/2023, 10:09 PMRezwan Abir
02/13/2023, 10:09 PMserialization_settings = SerializationSettings(
project="flytesnacks",
domain=self.settings.flyte_domain,
env=None,
image_config=ImageConfig(
default_image=Image(name="custom_container_task", fqn="<http://flyteorg.io/placeholder|flyteorg.io/placeholder>", tag="image")
),
)
self.remote.register_task(self.sum_test, version="1.0", serialization_settings=serialization_settings)
@task(cache=False, cache_serialize=False)
def sum_test(x: int, y: int) -> int:
return x + y
self.remote.register_task(self.sum_test, version="1.0", serialization_settings=serialization_settings)
self.remote.register_workflow(process_data_wf, version="1.0")
Error..... Value error! Received: None. No serialization settings set, but workflow contains entities that need to be registered. Type: <class 'flytekit.core.python_function_task.PythonFunctionTask'> app.flyte.client.sum_test
EXCEPTIN HERE...... The cached values aren't the same as the current call arguments
David Espejo (he/him)
02/13/2023, 11:06 PMEduardo Apolinario (eapolinario)
02/13/2023, 11:13 PMRezwan Abir
02/13/2023, 11:19 PMKetan (kumare3)
Rezwan Abir
02/14/2023, 4:32 AMserialization_settings = SerializationSettings(
project="flytesnacks",
domain=self.settings.flyte_domain,
env=None,
image_config=ImageConfig(
default_image=Image(
name="custom_container_task",
fqn="<http://flyteorg.io/placeholder|flyteorg.io/placeholder>",
tag="image",
)
),
)
currentAttempt done. Last Error: USER::containers with unready status: [fc4abba2e3b0246a7881-n0-0]|Back-off pulling image "<http://flyteorg.io/placeholder:image|flyteorg.io/placeholder:image>"
Eduardo Apolinario (eapolinario)
02/14/2023, 5:53 AM<http://cr.flyte.org/flyteorg/flytekit:py3.10-1.3.2|cr.flyte.org/flyteorg/flytekit:py3.10-1.3.2>
)Rezwan Abir
02/14/2023, 3:19 PMflytectl demo start
strict mode is on but received keys [map[airflow_version:{} database:{} deploy:{} identifier:{} version:{}]] to decode with no config assigned to receive them: failed strict mode check