Showing 110 of 110 total issues
Pipeline
has 25 functions (exceeds 20 allowed). Consider refactoring. Open
class Pipeline(ABC): """ Internal class that represents a pipeline of steps. :param pipeline_name: Name of the pipeline.
- Create a ticketCreate a ticket
Line length Open
Please follow the pull request submission template when submitting pull requests. The more detailed
- Read upRead up
- Create a ticketCreate a ticket
- Exclude checks
Trailing spaces Open
Redis version (if using `HAPipeline`):
- Read upRead up
- Create a ticketCreate a ticket
- Exclude checks
Line length Open
- Staggered node startup no longer causes mid-interval pipeline runs on other nodes in HA mode.
- Read upRead up
- Create a ticketCreate a ticket
- Exclude checks
Line too long (82 > 79 characters) Open
:param pipeline_interval_s: The interval in seconds between pipeline runs.
- Read upRead up
- Create a ticketCreate a ticket
- Exclude checks
Line too long (120 > 79 characters) Open
Adds a lock operation benchmark timing to the rolling average counter. Used for calculating mutex lookup delays.
- Read upRead up
- Create a ticketCreate a ticket
- Exclude checks
Line too long (86 > 79 characters) Open
self._context_middleware.append(ContextMetricsMiddleware(self._metrics_store))
- Read upRead up
- Create a ticketCreate a ticket
- Exclude checks
Line length Open
While this application is in a pre-alpha state, you may use the Issues tab of this project to submit security vulnerabilities. Include the following information (if possible):
- Read upRead up
- Create a ticketCreate a ticket
- Exclude checks
Line too long (113 > 79 characters) Open
The high availability pipeline allows for several machines to have the pipeline loaded at once. If one of the
- Read upRead up
- Create a ticketCreate a ticket
- Exclude checks
Line too long (107 > 79 characters) Open
keeps the interval defined by job_interval_s, and may not represent the exact time of the last run.
- Read upRead up
- Create a ticketCreate a ticket
- Exclude checks
Line too long (103 > 79 characters) Open
A composable pipeline that runs on a single host. Provides no high availability or fault tolerance.
- Read upRead up
- Create a ticketCreate a ticket
- Exclude checks
Line length Open
If you need help with implementing Watergrid in your project, and you do not feel you have encountered
- Read upRead up
- Create a ticketCreate a ticket
- Exclude checks
Trailing spaces Open
Watergrid version/commit:
- Read upRead up
- Create a ticketCreate a ticket
- Exclude checks
Lists should be surrounded by blank lines Open
- Dependencies for `MetricsExporter` and `PipelineLock` modules are no longer included in the base package and must
- Read upRead up
- Create a ticketCreate a ticket
- Exclude checks
Headers should be surrounded by blank lines Open
# WaterGrid-Python
- Read upRead up
- Create a ticketCreate a ticket
- Exclude checks
Lists should be surrounded by blank lines Open
- Watergrid lets you scale up to multi-node clusters by changing only a few
- Read upRead up
- Create a ticketCreate a ticket
- Exclude checks
Line too long (94 > 79 characters) Open
Unlocks the pipeline and appends the time taken to unlock to the lock timings counter.
- Read upRead up
- Create a ticketCreate a ticket
- Exclude checks
Line too long (80 > 79 characters) Open
PipelineVerifier.verify_pipeline_dependencies_fulfilled(pipeline._steps)
- Read upRead up
- Create a ticketCreate a ticket
- Exclude checks
Line too long (95 > 79 characters) Open
Checks that all dependencies of a single step are fulfilled by at least one other step.
- Read upRead up
- Create a ticketCreate a ticket
- Exclude checks
Line too long (105 > 79 characters) Open
Runs the pipeline in a blocking interval mode. Every job_interval_s seconds, the pipeline is run.
- Read upRead up
- Create a ticketCreate a ticket
- Exclude checks