code: def create_project_connection(self, create_connection_inputs, project):
          
          query_parameters = {}
          if project is not None:
              query_parameters['project'] = self._serialize.query('project', project, 'str')
          content = self._serialize.body(create_connection_inputs, 'CreatePipelineConnectionInputs')
          response = self._send(http_method='POST',
                                location_id='00df4879-9216-45d5-b38d-4a487b626b2c',
                                version='5.1-preview.1',
                                query_parameters=query_parameters,
                                content=content)
          return self._deserialize('PipelineConnection', response)
docs: CreateProjectConnection.
          [Preview API] Creates a new Pipeline connection between the provider installation and the specified project. Returns the PipelineConnection object created.
          :param :class:`<CreatePipelineConnectionInputs> <azure.devops.v5_1.cix.models.CreatePipelineConnectionInputs>` create_connection_inputs:
          :param str project:
          :rtype: :class:`<PipelineConnection> <azure.devops.v5_1.cix.models.PipelineConnection>`