class PipelineExecutionParams(graphene.InputObjectType):
    pipelineName = graphene.NonNull(graphene.String)
    config = graphene.Field(PipelineConfig)

    @staticmethod
    def validate(dict_):
        check.invariant(set(dict_.keys()) == set(['pipelineName', 'config']))
        return ExecutionParams(
            pipeline_name=check.str_elem(dict_, 'pipelineName'),
            config=dict_['config'],
        )