Skip to content
Snippets Groups Projects

Issue #3406391 by jibran: Add Gitlab CI support

Merged Jibran Ijaz requested to merge issue/data_pipelines-3406391:3406391-add-gitlab-ci into 1.x
1 unresolved thread
Files
24
@@ -6,6 +6,7 @@ use Drupal\Component\Utility\UrlHelper;
use Drupal\Core\Form\FormStateInterface;
use Drupal\Core\Plugin\ContainerFactoryPluginInterface;
use Drupal\Core\StringTranslation\TranslatableMarkup;
use Drupal\Core\Utility\Error;
use Drupal\data_pipelines\DatasetData;
use Drupal\data_pipelines\DatasetPipelinePluginManager;
use Drupal\data_pipelines\Destination\DatasetDestinationPluginBase;
@@ -82,7 +83,7 @@ class ElasticSearchDestination extends DatasetDestinationPluginBase implements C
* @param \Elasticsearch\Client|null $client
* The client. Used for testing.
*/
public function __construct(array $configuration, $plugin_id, $plugin_definition, DatasetPipelinePluginManager $pipeline_manager, LoggerInterface $logger, Client $client = NULL) {
final public function __construct(array $configuration, $plugin_id, $plugin_definition, DatasetPipelinePluginManager $pipeline_manager, LoggerInterface $logger, Client $client = NULL) {
parent::__construct($configuration + $this->defaultConfiguration(), $plugin_id, $plugin_definition);
$this->logger = $logger;
$this->client = $client;
@@ -93,7 +94,7 @@ class ElasticSearchDestination extends DatasetDestinationPluginBase implements C
/**
* {@inheritdoc}
*/
public static function create(ContainerInterface $container, array $configuration, $plugin_id, $plugin_definition) {
public static function create(ContainerInterface $container, array $configuration, $plugin_id, $plugin_definition): static {
return new static(
$configuration,
$plugin_id,
@@ -240,7 +241,7 @@ class ElasticSearchDestination extends DatasetDestinationPluginBase implements C
return $this->getClient()->ping();
}
catch (ElasticsearchException $e) {
watchdog_exception('data_pipelines', $e);
Error::logException($this->logger, $e);
return FALSE;
}
}
@@ -296,7 +297,7 @@ class ElasticSearchDestination extends DatasetDestinationPluginBase implements C
$this->getClient()->indices()->create($index_params_base + $index_params);
}
catch (\Exception $e) {
watchdog_exception('data_pipelines', $e);
Error::logException($this->logger, $e);
throw new CouldNotCreateIndexException(sprintf("Failed to create index %s", $index_id), 0, $e);
}
}
Loading