Hey, I'm trying PyFlink right now. I'm newbie in Python, and I'm trying to make Flink ProcessFunction

class AttributePretraining(ProcessFunction):

    def process_element(self, value, ctx: 'ProcessFunction.Context'):
        id = value['id']

        training_dto = TrainingDTO(id)

        return training_dto

But I got TypeError: AttributePretraining.open() missing 1 required positional argument: 'runtime_context' Any idea why is this happening

@Yaroslav Bezruchenko Could you paste the whole exception stack?