if run_config.task_definition_arn is None: # Register a new task definition self.logger.debug( "Registering new task definition for flow %s", flow_run.flow.id ) taskdef = self.generate_task_definition(flow_run, run_config) resp = self.ecs_client.register_task_definition(**taskdef)
option when running the agent, should'nt that fix this issue? 3. Also, is Prefect really the right tool for my usecase? I know Prefect has a lot of advanced features, but I am just looking for a cron that can run a huge amount of tasks easily on multiple nodes.