@@ -16,7 +16,7 @@ |
||
16 | 16 | */ |
17 | 17 | public function load(array $configs, ContainerBuilder $container) |
18 | 18 | { |
19 | - $loader = new YamlFileLoader($container, new FileLocator(\dirname(__DIR__).'/Resources/config')); |
|
19 | + $loader = new YamlFileLoader($container, new FileLocator(\dirname(__DIR__) . '/Resources/config')); |
|
20 | 20 | $loader->load('parameters.yml'); |
21 | 21 | $loader->load('services.yml'); |
22 | 22 | $loader->load('service-rule-transformers.yml'); |
@@ -10,8 +10,8 @@ |
||
10 | 10 | */ |
11 | 11 | class EtlExecution |
12 | 12 | { |
13 | - public const STATUS_WAITING ="waiting"; |
|
14 | - public const STATUS_QUEUED ="queued"; |
|
13 | + public const STATUS_WAITING = "waiting"; |
|
14 | + public const STATUS_QUEUED = "queued"; |
|
15 | 15 | public const STATUS_RUNNING = "running"; |
16 | 16 | public const STATUS_SUCCESS = "success"; |
17 | 17 | public const STATUS_FAILURE = "failure"; |
@@ -23,7 +23,7 @@ |
||
23 | 23 | $hour = str_pad(floor($time / 60 / 60), 1, '0'); |
24 | 24 | |
25 | 25 | $formattedPieces = []; |
26 | - if ($time > (60*60)) { |
|
26 | + if ($time > (60 * 60)) { |
|
27 | 27 | $formattedPieces[] = $hour . "h"; |
28 | 28 | } |
29 | 29 | if ($time > (60)) { |
@@ -28,7 +28,7 @@ |
||
28 | 28 | * @param ChainProcessorsManager $chainProcessorManager |
29 | 29 | * @param MessageBusInterface $messageBus |
30 | 30 | */ |
31 | - public function __construct(EntityManagerInterface $em, ChainProcessorsManager $chainProcessorManager, ?MessageBusInterface $messageBus =null) |
|
31 | + public function __construct(EntityManagerInterface $em, ChainProcessorsManager $chainProcessorManager, ?MessageBusInterface $messageBus = null) |
|
32 | 32 | { |
33 | 33 | $this->em = $em; |
34 | 34 | $this->chainProcessorManager = $chainProcessorManager; |
@@ -27,7 +27,7 @@ |
||
27 | 27 | } |
28 | 28 | |
29 | 29 | $logPath = $this->workDir . "/execution.log"; |
30 | - if(file_exists($logPath)) { |
|
30 | + if (file_exists($logPath)) { |
|
31 | 31 | $this->fileSystem->writeStream("execution.log", fopen($logPath, 'r')); |
32 | 32 | } |
33 | 33 | } |
@@ -37,7 +37,7 @@ discard block |
||
37 | 37 | } |
38 | 38 | try { |
39 | 39 | $fileSystem->delete(""); |
40 | - } catch (\Exception $exception){} |
|
40 | + } catch (\Exception $exception) {} |
|
41 | 41 | |
42 | 42 | $executionWorkDir = $this->chainWorkDirManager->getLocalTmpWorkDir($entity); |
43 | 43 | if (!file_exists($executionWorkDir)) { |
@@ -85,7 +85,7 @@ discard block |
||
85 | 85 | continue; |
86 | 86 | } |
87 | 87 | |
88 | - $files[] =$item; |
|
88 | + $files[] = $item; |
|
89 | 89 | } |
90 | 90 | |
91 | 91 | return $files; |
@@ -23,47 +23,47 @@ |
||
23 | 23 | $this->executionContext = $executionContext; |
24 | 24 | } |
25 | 25 | |
26 | - public function emergency(string|\Stringable $message, array $context = array()): void |
|
26 | + public function emergency(string | \Stringable $message, array $context = array()): void |
|
27 | 27 | { |
28 | 28 | $this->logger->emergency($message, $this->executionContext->getLoggerContext($context)); |
29 | 29 | } |
30 | 30 | |
31 | - public function alert(string|\Stringable $message, array $context = array()): void |
|
31 | + public function alert(string | \Stringable $message, array $context = array()): void |
|
32 | 32 | { |
33 | 33 | $this->logger->alert($message, $this->executionContext->getLoggerContext($context)); |
34 | 34 | } |
35 | 35 | |
36 | - public function critical(string|\Stringable $message, array $context = array()): void |
|
36 | + public function critical(string | \Stringable $message, array $context = array()): void |
|
37 | 37 | { |
38 | 38 | $this->logger->critical($message, $this->executionContext->getLoggerContext($context)); |
39 | 39 | } |
40 | 40 | |
41 | - public function error(string|\Stringable $message, array $context = array()): void |
|
41 | + public function error(string | \Stringable $message, array $context = array()): void |
|
42 | 42 | { |
43 | 43 | $this->logger->error($message, $this->executionContext->getLoggerContext($context)); |
44 | 44 | } |
45 | 45 | |
46 | - public function warning(string|\Stringable $message, array $context = array()): void |
|
46 | + public function warning(string | \Stringable $message, array $context = array()): void |
|
47 | 47 | { |
48 | 48 | $this->logger->warning($message, $this->executionContext->getLoggerContext($context)); |
49 | 49 | } |
50 | 50 | |
51 | - public function notice(string|\Stringable $message, array $context = array()): void |
|
51 | + public function notice(string | \Stringable $message, array $context = array()): void |
|
52 | 52 | { |
53 | 53 | $this->logger->notice($message, $this->executionContext->getLoggerContext($context)); |
54 | 54 | } |
55 | 55 | |
56 | - public function info(string|\Stringable $message, array $context = array()): void |
|
56 | + public function info(string | \Stringable $message, array $context = array()): void |
|
57 | 57 | { |
58 | 58 | $this->logger->info($message, $this->executionContext->getLoggerContext($context)); |
59 | 59 | } |
60 | 60 | |
61 | - public function debug(string|\Stringable $message, array $context = array()): void |
|
61 | + public function debug(string | \Stringable $message, array $context = array()): void |
|
62 | 62 | { |
63 | 63 | $this->logger->debug($message, $this->executionContext->getLoggerContext($context)); |
64 | 64 | } |
65 | 65 | |
66 | - public function log($level, string|\Stringable $message, array $context = array()): void |
|
66 | + public function log($level, string | \Stringable $message, array $context = array()): void |
|
67 | 67 | { |
68 | 68 | $this->logger->log($level, $message, $this->executionContext->getLoggerContext($context)); |
69 | 69 | } |