diff --git a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/TaskType.java b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/TaskType.java
index a6a3bac15..47d060511 100644
--- a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/TaskType.java
+++ b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/TaskType.java
@@ -37,6 +37,11 @@ public enum TaskType {
 
 
 
+    /**
+     * Step 10
+     */
+    FinishingSession,
+
     /**
      * Step 11
      */
diff --git a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/impl/EndStageNotification.java b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/impl/EndStageNotification.java
index ef76991c9..ad6481639 100644
--- a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/impl/EndStageNotification.java
+++ b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/impl/EndStageNotification.java
@@ -54,7 +54,7 @@ public class EndStageNotification implements ISessionStage {
     }
 
     protected Collection<Registry> selectRegistry() {
-        String registrySQL = "registryStatus=" + RegistryStatus.OK.getKey() + ")";
+        String registrySQL = "registryStatus='" + RegistryStatus.OK.getKey() + "'";
         Collection<Registry> result = registryImdg.getCollectionObjectsBySQL(registrySQL);
         log.trace("Selected {} registry's by sql: {}", result.size(), registrySQL);
         return result;
diff --git a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/task/FinishingSessionPayload.java b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/task/FinishingSessionPayload.java
new file mode 100644
index 000000000..9842cdc30
--- /dev/null
+++ b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/task/FinishingSessionPayload.java
@@ -0,0 +1,13 @@
+package ru.spcex.clearing.session.stage.task;
+
+public class FinishingSessionPayload {
+    private Long sessionId;
+
+    public Long getSessionId() {
+        return sessionId;
+    }
+
+    public void setSessionId(Long sessionId) {
+        this.sessionId = sessionId;
+    }
+}
diff --git a/platform-parent/platform-enum/src/main/java/ru/spcex/platform/enumeration/SessionStatus.java b/platform-parent/platform-enum/src/main/java/ru/spcex/platform/enumeration/SessionStatus.java
new file mode 100644
index 000000000..9f1c34986
--- /dev/null
+++ b/platform-parent/platform-enum/src/main/java/ru/spcex/platform/enumeration/SessionStatus.java
@@ -0,0 +1,26 @@
+package ru.spcex.platform.enumeration;
+
+import ru.spcex.platform.utils.enumeration.IEnumKey;
+
+public enum SessionStatus implements IEnumKey {
+    ACTV("ACTV"),
+    CLRN("CLRN"),
+    CLOS("CLOS");
+
+
+    SessionStatus(String key) {
+        this.key = key;
+    }
+
+    private String key;
+
+    @Override
+    public String getKey() {
+        return this.key;
+    }
+
+    @Override
+    public boolean equalsByKey(String key) {
+        return IEnumKey.super.equalsByKey(key);
+    }
+}