fix: Handle replication key not found in stream schema

[mjsqu]

Closes: #1332

Changes:

• Add new InvalidReplicationKeyException to singer_sdk.exceptions
• Update streams.core. A get() is used to obtain the replication_key from self.schema, if the key is not present in the schema, the variable type_dict would equal None. A check has been added, if the value of the type_dict is None then the new exception is raised
• The resulting error message is of the format:

"incorrect_replication_key" is not in schema for stream name: my_stream"

• Add a test to tests/core/test_streams.py which checks that a SimpleTestStream with replication_key overridden to "INVALID" raises the correct InvalidReplicationKeyException exception.

[codecov]

Codecov Report

Merging #1927 (0ca1e27) into main (4eac6f4) will increase coverage by 0.01%.
The diff coverage is 100.00%.

@@            Coverage Diff             @@
##             main    #1927      +/-   ##
==========================================
+ Coverage   86.96%   86.97%   +0.01%     
==========================================
  Files          59       59              
  Lines        5087     5091       +4     
  Branches      824      825       +1     
==========================================
+ Hits         4424     4428       +4     
  Misses        466      466              
  Partials      197      197              

Files Changed	Coverage Δ
singer_sdk/exceptions.py	100.00% <100.00%> (ø)
singer_sdk/streams/core.py	84.07% <100.00%> (+0.11%)	⬆️

📣 We’re building smart automated test selection to slash your CI/CD build times. Learn more

[edgarrmondragon]

Thanks for contributing @mjsqu! Just a small nit.

[edgarrmondragon]

Thanks @mjsqu!