<@app.route(‘/fis_prefect’, methods=[‘POST’])
def create_a_flow():
project_name = “test”
with Flow(“FIS”) as flow:
paramx = Parameter(“xssasasa”, default=None)
creating_cusip = create_cusip()
bloom_result = bloomberg_result(creating_cusip)
read_response__file(paramx)
if project_name:
flow_id = flow.register(project_name)
return"sucess"
This is working fine for the prefect 1.0 since I have moved it to prefect 2.0
<@task(name=“log-example-task”)
def logger_task_test():
logger = get_run_logger()
logger.info(“INFO level log message.”)
@flow(name=“Main Flow”)
def main_flow():
prefect_project = “s”
logger_task_test()
main_flow.register()>
not sure how to register it through api can some one help me plz thanks in advance