Peter Roelants
05/03/2021, 8:24 AMclass GetKafkaConfig(prefect.Task):
"""
Get Kafka configuration
"""
def run(
self,
timeout: timedelta
) -> KafkaConfig:
return KafkaConfig(
broker_address=os.environ['KAFKA_BROKER_ADDRESS'],
topic_name=os.environ['KAFKA_TOPIC_NAME'],
timeout=timeout
)
I would like to visualize these parameters in my prefect UI (and ideally make them editable), similar to how Parameter tasks can be visualized (e.g. as is demonstrated in https://docs.prefect.io/orchestration/tutorial/hello-flow-run-parameter-config.png▾
Kevin Kho
Peter Roelants
05/03/2021, 2:48 PMKevin Kho
Peter Roelants
05/03/2021, 3:10 PM