Method convert

backend/python/pydevlake/pydevlake/plugin.py:105–106

(self, ctx: Context, stream: str)

        return self._run_stream(ctx, stream, 'extractor')

    def convert(self, ctx: Context, stream: str):
        return self._run_stream(ctx, stream, 'convertor')

    def _run_stream(self, ctx: Context, stream_name: str, subtask: str):
        stream = self.get_stream(stream_name)